错误:分区0没有前导.跳过获取偏移

Question

我正在尝试确定主题的当前偏移量，我运行

bin/kafka-run-class.sh kafka.tools.GetOffsetShell

命令和我得到以下错误，可能发生了什么，我该如何修复？

Picked up _JAVA_OPTIONS: -Xmx4g
Error: partition 2 does not have a leader. Skip getting offsets
Error: partition 4 does not have a leader. Skip getting offsets
Error: partition 1 does not have a leader. Skip getting offsets
Error: partition 3 does not have a leader. Skip getting offsets
Error: partition 0 does not have a leader. Skip getting offsets

Answer 1

很可能您的Kafka代理已经停机。

你可以运行

kafka-topics --zookeeper host:2181 --describe --topic topic_name

看看Leader是否等于-1。如果是这种情况，那么您需要启动Kafka代理。

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