Найдите темы в группе потребителей в Kafka, используя Kafka- Python - PullRequest
Новая
       63

Найдите темы в группе потребителей в Kafka, используя Kafka- Python

0 голосов
/ 07 мая 2020

Входными данными моего python скрипта является имя группы потребителей, а выходными данными должен быть список тем в группе потребителей. В настоящее время мой код не возвращает темы, для которых текущее смещение равно -1. Есть ли лучший способ получить список всех тем в группе потребителей, используя Kafka- python. Я действительно хочу заменить описание topi c в группе cmd с помощью инструментов Kafka. 

from kafka import KafkaAdminClient
topics_in_groups = {};
client = KafkaAdminClient(bootstrap_server='localhost:9092')
for group in client.list_consumer_groups():
  topics_in_groups[group[0]] = [];
  topic_dict = client.list_consumer_group_offsets(group[0]);
  for topic in topic_dict:
    topics_in_groups[group[0]].append(topic.topic)
...