本地 kafka 集群“__consumer_offsets”领导者不可用

编程问答 2022-05-02

问题描述

我已经在 this blog 之后设置了一个本地 kafka 集群，但我无法让它工作。当我通过以下命令使用 CLI 时，我无法使用这些消息，因为它们没有出现。

./kafka-console-consumer.sh --bootstrap-server localhost:9093 --from-beginning --topic topic-1

./kafka-console-producer.sh --broker-list localhost:9093 --topic topic-1

经过一些故障排除后，我发现 kafkacat 所有 __consumer_offsets 都失去了他们的领导者。我认为这可能是我的问题。

3 brokers:
  broker 2 at kevin-UX390UAK:9094
  broker 3 at kevin-UX390UAK:9095
  broker 1 at kevin-UX390UAK:9093
 3 topics:
  topic "test-topic" with 1 partitions:
   ...
  topic "topic-1" with 3 partitions:
    partition 0,leader 2,replicas: 2,1,3,isrs: 1,2,3
    partition 2,leader 1,replicas: 1,3
    partition 1,leader 3,replicas: 3,3
  topic "__consumer_offsets" with 50 partitions:
partition 0,leader -1,replicas: 0,isrs: 0,broker: leader not available
    partition 10,broker: leader not available
    partition 20,broker: leader not available
    partition 40,broker: leader not available
    partition 30,broker: leader not available
    partition 9,broker: leader not available
    partition 11,broker: leader not available
    partition 31,broker: leader not available
    partition 39,broker: leader not available
    partition 13,broker: leader not available
    partition 18,broker: leader not available
    partition 22,broker: leader not available
    partition 8,broker: leader not available
    partition 32,broker: leader not available
    partition 43,broker: leader not available
    partition 29,broker: leader not available
    partition 34,broker: leader not available
    partition 1,broker: leader not available
    partition 6,broker: leader not available
    partition 41,broker: leader not available
    partition 27,broker: leader not available
    partition 48,broker: leader not available
    partition 5,broker: leader not available
    partition 15,broker: leader not available
    partition 35,broker: leader not available
    partition 25,broker: leader not available
    partition 46,broker: leader not available
    partition 26,broker: leader not available
    partition 36,broker: leader not available
    partition 44,broker: leader not available
    partition 16,broker: leader not available
    partition 37,broker: leader not available
    partition 17,broker: leader not available
    partition 45,broker: leader not available
    partition 3,broker: leader not available
    partition 24,broker: leader not available
    partition 38,broker: leader not available
    partition 33,broker: leader not available
    partition 23,broker: leader not available
    partition 28,broker: leader not available
    partition 2,broker: leader not available
    partition 12,broker: leader not available
    partition 19,broker: leader not available
    partition 14,broker: leader not available
    partition 4,broker: leader not available
    partition 47,broker: leader not available
    partition 49,broker: leader not available
    partition 42,broker: leader not available
    partition 7,broker: leader not available
    partition 21,broker: leader not available

知道是什么原因造成的？ 非常感谢！

凯夫

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafkakafka-cluster