一、问题描述

某次用户反馈，kafka消费这边消息失败，报错消费者被踢出消费组或broker状态异常无法连接，后实际验证端口确实不通

现场测试验证，报错：报错：Failed to find brokers to send ListGroups……find Coondinator失败，即leader找不到了

二、分析处理

2.1、现场查看消费者信息和topic情况发

如上所示，缺失找不到broker node，查看发现多了一个意外节点，经确认为非正常配置。

2.2、消费测试

2.3、权限确认

如上图所示，没有组权限；增加组权限

bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer
--authorizer-properties zookeeper.connect=172.18.1.112:2181 --add 
--allow-principal User:producer --operation Read --group test-group

发现topic的授权用户和consumer.properties里配置的消费用户名不一致

2.4 删除/下线多余的borker，迁移分区

broker 1（172.18.1.112）
broker 2（172.18.1.162 ）
broker 3（172.18.1.197）
broker 4 （172.18.1.198）------>下线该节点

#topic情况查看
./bin/kafka-topics.sh --describe --zookeeper 172.18.1.198:2181 --topic YWPT-*
#编写 kafka_rebalance_replicas.json

https://www.orchome.com/454
https://www.orchome.com/36
https://blog.csdn.net/qq_32907195/article/details/126236204