Как составить список всех производителей кластера кафки? - PullRequest
4 голосов
/ 20 февраля 2020

Я могу перечислить всех потребителей Kafka с помощью KafkaAdminClient:

AdminClient client = AdminClient.create(conf);
ListTopicsResult ltr = client.listTopics();
KafkaFuture<Set<String>> names = ltr.names();

ArrayList<ConsumerGroupListing> consumerGroups = new ArrayList<>(client.listConsumerGroups().all().get());
ConsumerGroupListing consumerGroup = consumerGroups.get(0);

Можно ли перечислить всех зарегистрированных производителей аналогичным образом?

1 Ответ

5 голосов
/ 20 февраля 2020

В отличие от потребителей, не можно получить такую ​​информацию, поскольку брокеры Kafka не хранят никакой информации о связанных с ними производителях.

...