如果从命令行进行尝试,则可以按以下方式使用kafka-consumer-groups.sh脚本。
bin/kafka-consumer-groups.sh --bootstrap-server <broker> --describe --group <group-name>
它将按以下方式返回数据:
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
testtopic-1 0 13164704 13164773 69 test-consumer-bf8d1655-63a6-4061-b680-0f11cdf182e5/100.96.67.0 test-consumer
testtopic-1 1 13161581 13161650 69 test-consumer-agent-bf8d1655-63a6-4061-b680-0f11cdf182e5/100.96.67.0 test-consumer
testtopic-1 2 12229509 12229578 69 test-consumer-bf8d1655-63a6-4061-b680-0f11cdf182e5/100.96.67.0 test-consumer
testtopic-1 3 86 86 0 test-consumer-agent-bf8d1655-63a6-4061-b680-0f11cdf182e5/100.96.67.0 test-consumer
如果使用Java,则可以使用
AdminClient.describeConsumerGroups
方法如下:
http://kafka.apache.org/20/javadoc/org/apache/kafka/clients/admin/AdminClient.html#describeConsumerGroups-java.util.Collection-
