代码之家 › 专栏 › 技术社区 › Vijay Kumar

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

apache-kafka

Vijay Kumar · 技术社区 · 6 年前

我试图确定一个主题的当前偏移量,我运行

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

1 回复 | 直到 6 年前

Giorgos Myrianthous 6 年前

很可能你的卡夫卡经纪人已经倒下了。

你可以跑

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

看看领队是否等于-1。如果是这样的话,你就需要启动卡夫卡经纪人。

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

推荐文章

elenwen · 在配置中发现未知的功能门KafkaNodePools

6 月前

ljuk · 连接器启动时的Debezium信号表

1 年前

Shubham Snehi · Golang Segmentation在消费者组迁移时获得一半分区

1 年前

RushHour · 无法定义Kafka配置的卷以便使用docker通过CLI启动生产者

1 年前

Hossein Rouhi · 优化Docker中的Kafka性能:单个ZooKeeper与多个、Broker计数的影响

1 年前

Narut Promsuparoj · Kafka连接器时间戳转换器与SMT一起使用时不工作

1 年前

user23351472 · 从卡夫集群中移除Broker的正确方法

1 年前

Varun Sharma · 从Kaffa主题消费并添加到列表中

1 年前

zloodeyka · Confluent rest prozy基本身份验证不起作用

1 年前

Kumar Saras · 我可以在Kafka Streams拓扑和普通Kafka消费者之间使用相同的组id吗?

1 年前