在Kafka中,获取特定主题的消费者列表的命令是什么

mwg9r5ms  于 2021-06-06  发布在  Kafka
关注(0)|答案(2)|浏览(489)

我知道我们可以得到消费者群体的列表,然后将其中任何一个消费者群体传递给特定的主题,以确定消费者抵消。
步骤1:使用以下命令获取使用者组列表

kafka-consumer-groups --zookeeper <Server-URL> --list

从获得的消费者列表中,选择一个消费者组步骤2:获取特定主题的特定消费者补偿

kafka-consumer-offset-checker --zookeeper <Server-URL> --topic <topic-name> --group <group-name>

引导服务器也是这样。
但在一个步骤中,我需要一个命令来获取特定主题的消费者列表。

piok6c0g

piok6c0g1#

__consumer_offsets 主题-主题/消费者列表。
我做了一个脚本这样做,这是相当缓慢的名单,但做的工作
https://gist.github.com/padilo/6a5101f9e005c975956208cb19ba9f67

mznpcxlj

mznpcxlj2#

据我所知,没有直接的命令:
一种解决方法是列出所有消费者群体

~ $ $KAFKA_DIR/bin/kafka-consumer-groups.sh -bootstrap-server localhost:9092 -list
consumer-group-1
consumer-group-2
consumer-group-3

然后使用下面显示主题的命令描述使用者组。

~ $ $KAFKA_DIR/bin/kafka-consumer-groups.sh --describe --bootstrap-server 0.0.0.0:9092 --group consumer-group-1

TOPIC                        PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                     HOST            CLIENT-ID
topic-1                      0          -               0               -               consumer-1-9bf71d08-bcf8-4eb1-adb8-91589fd034b3 /11.2.9.159     consumer-1

相关问题