要查看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)上的消费者实例的状态信息。