问题现象
可能原因
- 订阅该Topic分区的消费线程已经离线。
- Group触发Rebalance机制。在Rebalance过程中,Group的所有消费线程都停止消费。
- 您采用
assign
方式手动指定消费者读取某个Topic分区的消息,订阅关系已经明确,开源Kafka没有统计此信息。只有您采用subscribe
方式自动分配分区与消费者的订阅关系,客户端的具体信息才会显示。
assign
方式手动指定消费者读取某个Topic分区的消息,订阅关系已经明确,开源Kafka没有统计此信息。只有您采用subscribe
方式自动分配分区与消费者的订阅关系,客户端的具体信息才会显示。