要查看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。
通过这个命令行工具,可以方便地查看消费组的状态和消费者的消费进度,以便进行监控和故障排除。