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

1. 确保创建消费组时指定了相同的组ID：

props.put("group.id", "test-group");

2. 确保在消费者客户端代码中使用相同的消费者组ID：

consumerProperties.put("group.id", "test-group");

3. 检查分区的分配和重平衡是否正确，例如：

@Override
public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
    System.out.println("Partitions assigned:" + partitions);
}

@Override
public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
    System.out.println("Partitions revoked:" + partitions);
}

4. 如果您尝试重复读取相同的消息，则可以尝试将auto.offset.reset属性设置为earliest：

props.put("auto.offset.reset", "earliest");