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

Question

我能够用KafkaAdminClient列出所有Kafka Consumer：

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

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

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

Answer 1

不可能not检索此类信息，因为Kafka经纪人不存储有关与之连接的生产者并产生消息的任何类型的信息。