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

Question

我可以使用KafkaAdminClient 列出所有 Kafka 消费者：

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 代理不存储有关与其连接的生产者的任何类型的信息。