相关信息: Successfully joined group with generation xxx Setting newly assigned partitions [] 后续debug信息一直重复: Sending Heartbeat request to coordinator Received successful Heartbeat response poll一直拉不到消息 没有报错
Setting newly assigned partitions [],分配的分区时空的
问题提的太宽泛了,我都无从下手。
查询下消费者列表:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
某个组的消费情况:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group
你的答案