kafka查看消费组未消费数据情况0.9之后版本

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list //查看topicbin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list //查看消费组bin/kafka-consumer-groups.sh --new-consum...

wo1769815

6276人浏览 · 2019-09-16 16:11:53

wo1769815 · 2019-09-16 16:11:53 发布

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list //查看topic

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list //查看消费组

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group daemon //查看消费情况

Group : 消费者组
Topic : topic的名字
Pid : partition的ID
Offset : kafka消费者在对应分区上已经消费的消息数【位置】
logSize : 已经写到该分区的消息数【位置】
Lag : 还有多少消息未读取（Lag = logSize - Offset）
Owner : 分区创建在哪个broker