logstash作为kafka的消费者的时候,获取不到kafka中组的信息

作者 aslan | 发布于2018年08月16日 | 阅读数:317

求教,前提是使用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 却可以列出消费者组中的消息的情况,哪位大神能不能帮忙看下
已邀请:

zqc0512 - andy zhou

赞同来自:

Note: This will not show information about old Zookeeper-based consumers.
有变化的,命令好像有改变。
 

aslan

赞同来自:

我使用的新版本,所以消费者组信息是保存在broker上的,我在使用命令获取组信息的时候也指定了--bootstrap-server的

要回复问题请先登录注册