Kafka消费者组异常：消息仅单消费者接收+命令执行报错

1. 消费者组描述命令的错误修复 #

你执行命令时存在两处拼写错误：

• 将localhost误写为locahost，导致DNS解析失败；
• 组名写成了my-group，但启动消费者时指定的组名是my_group（下划线 vs 横杠）。

纠正后的正确命令：

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group

执行该命令可以查看消费组的分区分配、成员状态等关键信息，为后续排查提供依据。

2. 所有消息仅路由至单个消费者的核心原因及解决 #

原因一：生产者消息全部集中在同一个分区 #

Kafka的分区路由逻辑：

• 若发送消息时使用了相同的key，Kafka会通过key的哈希值将所有消息路由到同一个分区；而同一个分区只能被消费组内的一个消费者处理，因此另一个消费者会收不到消息。
• 你使用的kafka-console-producer.sh默认不指定key，此时默认分区器会轮询将消息分发到3个分区，但如果手动发送时用了key:value格式且key相同，就会出现消息集中的情况。

解决方式：

• 无需按key分区时，直接发送纯文本消息（不带key前缀），生产者会自动轮询分配到不同分区；
• 需要按key分区时，确保使用不同的key发送消息，让消息分散到多个分区。

原因二：消费者未成功加入同一消费组 #

虽然启动时指定了--group my_group，但可能存在以下情况：

• 其中一个消费者启动后出现连接错误，未成功加入组；
• 启动消费者时组名输入错误（比如误写为my-group）。

解决方式：

• 查看两个消费者的启动日志，确认是否有连接或加入组的报错信息；
• 用上述纠正后的消费者组描述命令，确认组内存在两个消费者实例，且分区被分配给了不同的消费者。

原因三：分区分配策略导致的消息集中（少见） #

Kafka默认采用Range分配策略，对于3个分区、2个消费者的场景，分配结果通常是：消费者1分到分区0、1，消费者2分到分区2。若你的消息恰好都发送到了分区0、1，消费者2就会收不到消息。

解决方式：
启动消费者时指定RoundRobin分配策略，让分区均匀分配：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic logs --group my_group --partition-assignment-strategy org.apache.kafka.clients.consumer.RoundRobinAssignor

内容的提问来源于stack exchange，提问作者Vinnie