Kafka2.12ConsumerGroup(带命令提示符)-第二个消费者无法接收消息？

这个问题的原因可能是由于配置文件或代码中的一些错误导致的。以下是一些可以参考的

1. 确认消费者组名称是否正确：

在消费者代码中，通过设置消费者的groupId来指定一个消费者组名称，应该保证groupName唯一，这是非常关键的。如果这两个消费者的groupId不同，第二个消费者无法加入第一个消费者的消费者组，这就导致无法接收到消息。可以尝试修改groupId并重新运行消费者并查看结果。

2. 检查Kafka版本是否与依赖库相匹配：

Kafka的版本和依赖库必须匹配，否则可能会导致不可预测的结果。因此，请确保在编译或使用Maven库时使用的Kafka版本与实际生产环境中的版本匹配。可以在代码中添加以下行来检查版本号：System.out.println(org.apache.kafka.common.utils.VersionFor.class.getPackage().getImplementationVersion());

3. 确认是否存在消息或是否在分区中：

如果分区中没有可用消息，则消费者无法接收到消息。可以尝试发送一些消息以确保消息可用并且消费者能够接收。

此外，以后可考虑使用kafka自带的kafkacat进行测试。例如：

• 生产者用 kafkacat:

  kafkacat -P -b <host> <port> -t my_topic
  hello, kafka!
  
  

• 消费者 1 用 kafkacat:

  kafkacat -C -b <host> <port> -t my_topic -g my_group
  hello, kafka!
  
  

• 消费者 2 也用 kafkacat:

  kafkacat -C -b <host> <port> -t my_topic -g my_group
  hello, kafka!
  

反复测试 kafkacat 发送和接受数据以至于消费者2能收到消息为止。