怎么查看Kafka的Topic消费情况
时间: 2023-08-07 07:04:57 浏览: 157
kakfa-monitor:通过监控kafka偏移量的topic来监控kafka的消费状态
你可以使用 Kafka 自带的命令行工具 `kafka-consumer-groups.sh` 来查看 Topic 的消费情况。具体操作如下:
1. 打开终端,进入 Kafka 安装目录的 `bin` 文件夹。
2. 执行以下命令查看消费者组中的消费情况:
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group your-consumer-group
```
其中,`--bootstrap-server` 参数指定了 Kafka 集群的地址和端口,`--describe` 参数表示要查看消费情况,`--group` 参数指定了消费者组的名称。
3. 执行以上命令后,你将会看到输出结果,其中包含了每个消费者的消费情况,例如:
```
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
your-topic 0 100 200 100 consumer-1-4bbae63a-3c50-4f6a-b5a9-6d5d9f13a3da /192.168.0.1 consumer-1
your-topic 1 120 200 80 consumer-1-4bbae63a-3c50-4f6a-b5a9-6d5d9f13a3da /192.168.0.2 consumer-1
your-topic 2 70 200 130 consumer-2-4bbae63a-3c50-4f6a-b5a9-6d5d9f13a3da /192.168.0.3 consumer-2
```
其中,`CURRENT-OFFSET` 表示消费者当前已经消费的消息的偏移量,`LOG-END-OFFSET` 表示该分区的最新偏移量,`LAG` 表示当前消费者还有多少条未消费的消息。
阅读全文