版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/xiewenbo/article/details/87695400
在0.9.0.0,kafka.tools.ConsumerOffsetChecker已经不支持了。你应该使用kafka.admin.ConsumerGroupCommand(或bin/kafka-consumer-groups.sh脚本)来管理消费者组,包括用新消费者API创建的消费者。
bin/kafka-consumer-groups.sh --group group_id --describe --bootstrap-server hostname:port
返回:
TOPIC
PARTITION
CURRENT-OFFSET
LOG-END-OFFSET
LAG
CONSUMER-ID
HOST
CLIENT-ID
[root@master bin]# kafka-consumer-groups.sh --new-consumer --bootstrap-server 192.168.75.128:9092 --group group --describe
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER
group producer_consumer_java_test_20181009 0 2436 2437 1 consumer-1_/192.168.75.1
group test_find1 0 303094 303094 0 consumer-1_/192.168.75.1
group test_find1 1 303068 303068 0 consumer-1_/192.168.75.1
group test_find1 2 303713 303713 0 consumer-1_/192.168.75.1