kafka服务器:偏移量的主题尚未创建

x4shl7ld  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(819)

我用的是kafka服务器0.9+zookeper。我是Kafka的新人。它在virtualbox中运行,我可以使用公共ip连接到它,这样它就可以工作了。。。或多或少:可以获取主题和消息。所以现在我有两个问题:
我在消费者偏移量处找不到任何内容(空),这就是为什么我遇到了go simple consumer脚本抛出错误的原因: kafka server: Offset's topic has not yet been created ; 当我通过命令检查zookeeper-shell.sh控制台时 ls /brokers/topics/__consumer_offsets 这让我很困惑: Node does not exist: /brokers/topics/__consumer_offsets (可能它们是连接在一起的)我在自动创建主题时得到了一个小警告: WARN NetworkClient - Error while fetching metadata with correlation id 4157 : {topicName=LEADER_NOT_AVAILABLE} 非常感谢您的帮助。谢谢!

icnyk63a

icnyk63a1#

这个 __consumer_offsets 当使用组的使用者连接到集群时,将自动创建主题。
默认情况下,sarama不支持组(https://github.com/shopify/sarama/wiki/frequently-asked-questions#how-can-i-use-sarama-to-monitor-or-join-a-consumer-group),所以除非您使用集群扩展(https://github.com/bsm/sarama-cluster)这是意料之中的。
你可以用 kafka-console-consumer.sh Kafka随附的工具,如果你想创建它。

svujldwt

svujldwt2#

在日志中成功找到原因: Number of alive brokers '1' does not meet the required replication factor '3' for the offsets topic 你需要把它贴到你的邮箱里 server.properties 文件以下选项: offsets.topic.replication.factor=1 . 这个选项不会让你做任何事情,直到计数达到3,但因为你有它设置为一个播放框-你通常只有1。

相关问题