Что такое команда для получения списка потребителей определенной темы в Кафке

Question

Я знаю, что мы можем получить список групп потребителей и затем передать любую из групп потребителей в конкретную тему, чтобы определить смещение потребителей.

Шаг 1: Используйте следующую команду, чтобы получить список потребителейgroups

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

Из полученного списка потребителей выберите группу потребителей. Шаг 2: Получите это конкретное смещение потребителя для определенной темы

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

То же самое для сервера начальной загрузки.

Но за один шаг мне нужна команда, чтобы получить список потребителей по определенной теме.

Answer 1

Способ извлечь это для всех потребителей - получить из темы __consumer_offsets список тем / потребителей.

Я сделал для этого скрипт, получить список довольно медленно, норабота

https://gist.github.com/padilo/6a5101f9e005c975956208cb19ba9f67

Answer 2

Насколько я знаю, прямой команды для этого не существует:

Одним из обходных путей для этого может быть перечисление всех групп потребителей

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