求教,前提是使用logstash从kafka中取数据,kafka是新版的。我想看到某个消费组中剩余了多少消息没有被消费,可以列出消费组:
[root@elk01 broker1]# bin/kafka-consumer-groups.sh --bootstrap-server 10.1.10.25:9092 --list
Note: This will not show information about old Zookeeper-based consumers.
logstash-data1
但是再详细看消费组中消息的具体情况时就什么也没有了:
[root@elk01 broker1]# bin/kafka-consumer-groups.sh --bootstrap-server 10.1.10.234:9092 --describe --group logstash-data1
Note: This will not show information about old Zookeeper-based consumers.
[root@elk01 broker1]#
使用kafka自带的消费者脚本bin/kafka-console-consumer.sh 却可以列出消费者组中的消息的情况,哪位大神能不能帮忙看下
[root@elk01 broker1]# bin/kafka-consumer-groups.sh --bootstrap-server 10.1.10.25:9092 --list
Note: This will not show information about old Zookeeper-based consumers.
logstash-data1
但是再详细看消费组中消息的具体情况时就什么也没有了:
[root@elk01 broker1]# bin/kafka-consumer-groups.sh --bootstrap-server 10.1.10.234:9092 --describe --group logstash-data1
Note: This will not show information about old Zookeeper-based consumers.
[root@elk01 broker1]#
使用kafka自带的消费者脚本bin/kafka-console-consumer.sh 却可以列出消费者组中的消息的情况,哪位大神能不能帮忙看下
2 个回复
zqc0512 - andy zhou
赞同来自:
有变化的,命令好像有改变。
aslan
赞同来自: