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

Question

我知道我们可以获取消费者组列表，然后将消费者组中的任何一个传递给特定主题以确定消费者偏移量。

第一步：使用以下命令获取消费组列表

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

从获得的消费者列表中，选择一个消费者组 步骤 2：获取特定主题的特定消费者偏移量

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

引导服务器也是如此。

但是在一个步骤中，我需要一个命令来获取特定主题的消费者列表。

Answer 1

据我所知，没有直接命令可以做到这一点：

解决此问题的一种方法可能是列出所有消费者组

~ $ $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