【问题标题】:Error: partition x does not have a leader. Skip getting offsets - But describe shows leader is present错误:分区 x 没有领导者。跳过获取偏移量 - 但描述显示领导者在场
【发布时间】:2019-09-26 10:48:33
【问题描述】:

错误:分区 0 没有领导者。跳过获取偏移量 - 但描述显示领导者在场

Error: partition 0 does not have a leader. Skip getting offsets 我也遇到了同样的问题,但是 --describe 说领导在场,请问您有什么解决办法吗?谢谢

Kafka 代理状态更改日志显示:

[timestamp] ERROR [Controller id=**** epoch=**] Controller **** epoch ** failed to change state for partition ********* from OfflinePartition to OnlinePartition (state.change.logger)
kafka.common.StateChangeFailedException: Failed to elect leader for partition ********** under strategy OfflinePartitionLeaderElectionStrategy

再次感谢,总代理数为 4,partitioncount 为 3,replicationfactor 为 4。

请注意,消费者不会在 zookeeper 上写入偏移量

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list broker1:6667,broker2:6667 --topic topic1 --time -1

Error: partition 2 does not have a leader. Skip getting offsets 
Error: partition 1 does not have a leader. Skip getting offsets 
Error: partition 0 does not have a leader. Skip getting offsets

./kafka-topics.sh --describe --zookeeper zookeepernode01:2181 --topic topic1 

Topic: topic1 PartitionCount:3 ReplicationFactor:4 Configs: Topic: topic1

Partition: 0 Leader: 2 Replicas: 2,4,6,7 Isr: 2,4,6 Topic: topic1 
Partition: 1 Leader: 3 Replicas: 3,6,7,8 Isr: 3,7,8 Topic: topic1 
Partition: 2 Leader: 4 Replicas: 4,7,8,1001 Isr: 4,7 Topic: topic1

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

    已解决,问题是基础架构从 4 个代理更改为 3 个代理,并且主题相同。所以有一些topic不存在leader,他们也无法删除,所以删除是通过zookeeper cli强制删除:

    How to Delete a topic in apache kafka

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2021-11-08
      • 1970-01-01
      • 1970-01-01
      • 2021-10-12
      • 2016-03-21
      • 2017-01-09
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多