kafkaError: Executing consumer group command failed due to org.apache.kafka.common.KafkaException

原创 kafka
明仔闯天涯 发表于: 2021-09-18   最后更新时间: 2021-09-18 19:32:41   224 游览

大佬我这边kafka报这个错

2021-09-18 19:23:19 |WARN |org.springframework.kafka.KafkaListenerEndpointContainer#4-0-C-1 |org.apache.kafka.clients.NetworkClient:961 |[Consumer clientId=consumer-6, groupId=myGroup] 1 partitions have leader brokers without a matching listener, including [rdsQuickRealTimeTopic-0]

然后执行

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

会报

Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups
java.util.concurrent.ExecutionException: org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups



添加评论

这个错误一般是server.properties中kafka网络配置不对,比如你配置的是:

listeners=PLAINTEXT://你的内网ip:9092

则命令就不得使用localhost了,使用对应的ip,如:

./kafka-consumer-groups.sh --bootstrap-server 你的内网ip:9092 --list

另外,你没提供相应的kafka版本,提供给你不同版本的消费者列表查询:

## 消费者列表查询(存储在zk中的)
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list

## 消费者列表查询(支持0.9版本+)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list

## 消费者列表查询(支持0.10版本+)
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

命令来自:kafka命令大全

你的答案

查看kafka相关的其他问题或提一个您自己的问题

找不到想要的答案?提一个您自己的问题。

我要提问
提问