如何列出Kafka集群的所有生产者?

ykejflvf  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(542)

我可以列出所有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);

有没有可能以类似的方式列出所有注册的生产商?

hvvq6cgz

hvvq6cgz1#

与消费者不同的是,由于Kafka经纪人不存储与他们有关的生产者的任何信息,因此无法检索此类信息。

相关问题