2

我正在使用 Kafka 服务器 0.9 + zookeper。我是卡夫卡的新手。它在 virtualbox 中运行，我可以使用公共 IP 连接到它，所以它可以工作......或多或少：可以获取主题和消息。所以现在我有两个问题：

  1. 我在 __consumer_offsets (empty) 找不到任何东西，这就是为什么我遇到 go simple consumer script throwing 错误的问题：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

  2. （也许它们是连接的）我在自动创建主题时收到了轻微警告：WARN NetworkClient - Error while fetching metadata with correlation id 4157 : {topicName=LEADER_NOT_AVAILABLE}

它高度赞赏任何帮助。谢谢！

4

2 回答 2

1

当__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 附带的工具来创建它。

于 2018-03-26T13:37:57.070 回答
1

原因已在日志中成功找到：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 个。

于 2018-03-26T13:50:12.783 回答