当我点击/v2/kafka/local/consumer时,得到以下响应:
{“error”:false,“message”:“consumer list returned”,“consumers”:[],“request”:{“url”:“/v2/kafka/local/consumer”,“host”:“en navneetj”,“cluster”:“local”,“group”:“,”topic“}}}我的配置文件如下:
配置
当我运行bin/kafka-consumer-groups.sh--list--zookeeper时localhost:2181 i 获取以下消费群。。
console-consumer-98785 console-consumer-1054 console-consumer-70637 console-consumer-69177 console-consumer-16166 console-consumer-62362 console-consumer-24827 console-consumer-12034 console-consumer-72951
为什么我不能在巴罗拿到这份名单。
此外,我也无法获得这些消费者群体在burrow的滞后或其他细节。
我能得到一些帮助吗?
1条答案
按热度按时间mlmc2os51#
默认情况下,控制台使用者使用旧使用者并在zookeeper中创建组。巴罗假设新的消费者和预期的团体在Kafka。
检查是否可以使用--new标志运行控制台使用者,以便它将使用新使用者,从而使用burrow。