我知道我们可以得到消费者群体的列表,然后将其中任何一个消费者群体传递给特定的主题,以确定消费者抵消。
步骤1:使用以下命令获取使用者组列表
kafka-consumer-groups --zookeeper <Server-URL> --list
从获得的消费者列表中,选择一个消费者组步骤2:获取特定主题的特定消费者补偿
kafka-consumer-offset-checker --zookeeper <Server-URL> --topic <topic-name> --group <group-name>
引导服务器也是这样。
但在一个步骤中,我需要一个命令来获取特定主题的消费者列表。
2条答案
按热度按时间piok6c0g1#
从
__consumer_offsets
主题-主题/消费者列表。我做了一个脚本这样做,这是相当缓慢的名单,但做的工作
https://gist.github.com/padilo/6a5101f9e005c975956208cb19ba9f67
mznpcxlj2#
据我所知,没有直接的命令:
一种解决方法是列出所有消费者群体
然后使用下面显示主题的命令描述使用者组。