如何列出kafka集群的所有生产者？

Question

我能够列出所有 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);

是否可以用类似的方式列出所有注册的生产商？

Answer 1

与消费者相反，不可能检索此类信息，因为 Kafka 代理不存储任何类型的有关与其连接的生产者的信息。