如何查看当前的gruop_id 的kafka 消费情况   这个可以查看到是否存在消费阻塞问题 

命令如下:

/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group GWW --describe

其中  127.0.0.1  为zookeeper 服务器ip

GWW 为对应要查看的group_id 

如下图所示:

运行这个命令后，Kafka会返回指定消费者组的以下信息：

• 每个分区的当前偏移量（offset）。
• 消费者的消费进度（消费到哪个偏移量）。
• 分区的滞后（lag），即消息队列中未消费的消息数量。