我在玩弄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,我没有花时间建立自己的)
1条答案
按热度按时间p3rjfoxz1#
可能是,但可能不是。我的猜测是,这个主题并没有被创造出来,所以Kafka卡特在屏幕上呼应了这个按摩,但并没有真正把它发送给Kafka。删除/tmp/kafka日志后,所有主题都可能被删除
不,我不认为这是寻找解决办法的方法。
拥有一个docker容器绝对是一个不错的选择—您很快就会在多个代理上运行kafka,检查复制行为、高可用性场景等。。把它放在码头上很有帮助。