要查看Kafka消費者組信息,您可以使用Kafka自帶的命令行工具kafka-consumer-groups.sh
。請按照以下步驟操作:
打開命令行終端。
使用以下命令格式運行kafka-consumer-groups.sh
腳本:
./kafka-consumer-groups.sh --bootstrap-server <kafka_broker_address> --describe --group <consumer_group_id>
其中,<kafka_broker_address>
是Kafka代理服務器的地址(例如:localhost:9092),<consumer_group_id>
是您要查詢的消費者組ID。
例如,要查看名為my-consumer-group
的消費者組的信息,您可以運行以下命令:
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-consumer-group
執行此命令后,您將看到類似以下的輸出:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
my-consumer-group my-topic 0 100 100 0 consumer-1-b7d8f45c-1a9e-4a9b-8d8a-4c9e7b121a3d /127.0.0.1 consumer-1
my-consumer-group my-topic 1 200 200 0 consumer-1-b7d8f45c-1a9e-4a9b-8d8a-4c9e7b121a3d /127.0.0.1 consumer-1
這個輸出顯示了消費者組my-consumer-group
在不同主題(my-topic
)和分區(0和1)上的消費者實例的狀態信息。