错误：分区x没有领导者。跳过获取偏移量-但Description显示leader在场
错误：分区0没有领导。跳过获取偏移量-但Description显示leader在场
[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
请注意，consumer没有在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
共有1个答案
解决了，问题是基础设施从4个经纪人变成了3个经纪人，题目也是一样的。所以有一些主题不存在的领导者，他们也是不可能删除的，所以删除是通过zookeeper cli强制删除：
如何在apache kafka中删除主题
-
当我在Android Studio上运行时 flutter驱动器--target=test_driver/app.dart 我得到了这个输出 文件：///c:/flutter/packages/flutter_test/lib/src/accessibility.dart:8:8:错误：找不到：“dart:ui”将“dart:ui”导入为UI； 文件：///c:/flutter/packages/
-
第一次与Kafka和多克合作。我正试图向Kafka发布一条消息，但出现了一个错误（请看下面）。问题是什么？ 2020-07-21 16:37:40274警告[Kafka制作人网络线程|制作人-1]组织。阿帕奇。Kafka。客户。NetworkClient$DefaultMetadataUpdater:[Producer-clientId=Producer-1]1个分区的前导代理没有匹配的侦听器，包
-
问题内容： 现在，Golang Kafka库（sarama）提供了使用者组功能，而kafka 10没有任何外部库帮助。如何在任何给定时间获得使用者组正在处理的当前消息偏移量？ 以前，我使用kazoo-go（https://github.com/wvanbergen/kazoo- go ）来获取我的消费者组消息偏移量，因为它存储在Zookeeper中。现在，我使用sarama- cluster（ht
-
我正在努力通过SSL移动所有Kafka流量。每个区域有两个集群。 使用Kafka 2.7.0版。 除一个集群外，所有区域和所有集群都可以通过SSL正常工作。 在其他工具中，我使用< code>kafkacat来探测集群。 当通过明文连接对此集群执行时，它会列出所有代理、主题和分区，并显示每个分区的领导者： 当通过 SSL 执行相同的命令时，会发现： 0经纪人 列出主题和分区，但没有标题 对该地区的
-
我正在使用Kafka2.0版和java消费者API来消费来自一个主题的消息。我们使用的是一个单节点Kafka服务器，每个分区有一个使用者。我注意到消费者正在丢失一些消息。场景是：消费者投票主题。我为每个线程创建了一个消费者。获取消息并将其交给处理程序来处理消息。然后使用“至少一次”的Kafka消费者语义来提交Kafka偏移量来提交偏移量。同时，我有另一个消费者使用不同的group-id运行。在这个
-
问题内容： 是否可以获得每个突出显示的片段的字符位置？我需要将突出显示的文本与源文档匹配，并且使用字符位置将使其成为可能。 例如： 返回此突出显示： 如果匹配的文档中的字段消息是： 有没有办法知道该摘要从匹配字段的char 8开始到char 21？ 知道匹配 令牌 的开始/结束偏移量对我也很有益-也许有一种方法可以使用script_fields访问该信息？显示了如何获取令牌，而不是偏移量）。 “消