如何解决在尝试消费时出现的“leader not available”kafka错误

5kgi1eie  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(854)

我在玩弄Kafka,使用我自己本地的zookeeper+kafka的单个示例,遇到了这个我似乎不知道如何解决的错误。
我根据apachekafka快速入门指南启动了一个简单的服务器

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

然后利用kafkacat(通过自制软件安装)我创建了一个生产者,它只回显我在控制台中键入的消息

$ 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)

我的问题:
这是我运行的zookeeper和/或kafkacat示例的问题吗?我问这个问题是因为我一直在不断地关闭它们,然后在删除 /tmp/zookeeper 以及 /tmp/kafka-logs 目录
有什么简单的设置我需要试试吗?我试着添加 auto.leader.rebalance.enable=true 在Kafka的 server.properties 设置文件,但没有解决这个问题
如何重新启动zookeeper/kafka。正在关闭它们,删除 /tmp/zookeeper 以及 /tmp/kafka-logs 目录,然后重启zookeeper,然后Kafka怎么办(好吧,也许方法是建立一个docker容器,我可以站起来拆掉,我打算使用spotify/docker kafka容器,但这不是kafka 0.9.0.0,我没有花时间建立自己的)

p3rjfoxz

p3rjfoxz1#

可能是,但可能不是。我的猜测是,这个主题并没有被创造出来,所以Kafka卡特在屏幕上呼应了这个按摩,但并没有真正把它发送给Kafka。删除/tmp/kafka日志后,所有主题都可能被删除
不,我不认为这是寻找解决办法的方法。
拥有一个docker容器绝对是一个不错的选择—您很快就会在多个代理上运行kafka,检查复制行为、高可用性场景等。。把它放在码头上很有帮助。

相关问题