要查看Kafka消費組的情況,可以使用Kafka自帶的命令行工具kafka-consumer-groups.sh
。以下是使用該命令行工具查看消費組情況的步驟:
打開終端,并導航到Kafka的安裝目錄。
運行以下命令,替換<bootstrap_servers>
和<group_id>
為實際的Kafka集群地址和消費組ID:
bin/kafka-consumer-groups.sh --bootstrap-server <bootstrap_servers> --group <group_id> --describe
示例輸出:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
my-group my-topic 0 100 200 100 consumer-1-1a2b 192.168.1.100 consumer-1
my-group my-topic 1 150 200 50 consumer-1-1a2b 192.168.1.100 consumer-1
在上面的示例中,可以看到消費組my-group
正在消費my-topic
的兩個分區。每個分區的消費進度、日志末尾偏移量和滯后量都顯示出來。此外,還可以看到每個消費者的消費者ID、主機和客戶端ID。
通過這個命令行工具,可以方便地查看消費組的狀態和消費者的消費進度,以便進行監控和故障排除。