6

我正在玩 Kafka 并使用我自己的本地单一实例 zookeeper + kafka 并遇到这个我似乎不明白如何解决的错误。

我根据Apache Kafka 快速入门指南启动了一个简单的服务器

$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-server-start.sh config/server.properties

然后利用kafkacat（通过 Homebrew 安装）我启动了一个 Producer，它只会回显我在控制台中输入的消息

$ kafkacat -P -b localhost:9092 -t TestTopic -T
test1
test1

但是当我尝试使用这些消息时，我得到一个错误：

$ kafkacat -C -b localhost:9092 -t TestTopic
% ERROR: Topic TestTopic error: Broker: Leader not available

同样，当我尝试列出它的元数据时

$ kafkacat -L -b localhost:9092 -t TestTopic
Metadata for TestTopic (from broker -1: localhost:9092/bootstrap):
 0 brokers:
 1 topics:
  topic "TestTopic" with 0 partitions: Broker: Leader not available (try again)

我的问题：

  1. /tmp/zookeeper这是我正在运行的 zookeeper 和/或 kafkacat 实例的问题吗？我问这个问题是因为在删除和/tmp/kafka-logs目录后，我一直在不断地关闭它们并重新启动它们
  2. 我需要尝试一些简单的设置吗？我尝试添加auto.leader.rebalance.enable=trueKafka 的server.properties设置文件，但这并没有解决这个特定问题
  3. 如何重新启动 zookeeper/kafka。是关闭它们，删除/tmp/zookeeper和/tmp/kafka-logs目录，然后重新启动zookeeper，然后再重新启动kafka吗？（好吧，也许要走的路是构建一个我可以站立和拆卸的 docker 容器，我打算使用spotify/docker-kafka容器，但它不在 Kafka 0.9.0.0 上，我没有采取是时候建立我自己的了）
4

1 回答 1

5
  1. 可能是，但可能不是。我的猜测是没有创建主题，因此 kafkacat 会在屏幕上呼应按摩，但并没有真正将其发送给 kafka。删除 /tmp/kafka-logs 后可能会删除所有主题
  2. 不，我认为这不是寻找解决方案的方法。
  3. 拥有一个 docker 容器绝对是要走的路——你很快就会在多个代理上运行 kafka，检查复制行为、高可用性场景等。让它 dockerised 有很大帮助。
于 2016-02-07T23:10:27.493 回答