这个提示是因为 sarama 使用的 Kafka 版本在 0.9.0.0 及以上,这个版本引入了一个内置的 topic,叫做 '__consumer_offsets',用于存储消费者组的偏移量信息。这个 topic 是 Kafka 自己维护的,不需要用户手动创建,但是在 Kafka 启动的时候需要一定的时间来初始化,所以在 sarama 连接 Kafka 集群时可能会出现这个提示。

如果这个提示出现在程序的启动阶段,可以等待一段时间后再重新连接,或者使用 sarama 的 WithMaxRetry(int) 参数来设置最大重试次数。如果这个提示出现在程序运行的过程中,可能是因为 Kafka 集群的某个节点出现了问题,可以检查 Kafka 集群的状态来排查问题。

解决 sarama 错误提示:'the __consumer_offsets topic is not initialized completely yet'

原文地址: https://www.cveoy.top/t/topic/lyBP 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录