我用的是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} 非常感谢您的帮助。谢谢！
2条答案
按热度按时间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.shKafka随附的工具，如果你想创建它。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。