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

原创

明仔闯天涯 发表于: 2021-09-18 最后更新时间: 2021-09-18 19:32:41 6,932 游览

大佬我这边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

原创 kafka

发表于 2021-09-18

明仔闯天涯

添加评论

这个错误一般是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