我可以使用 KafkaAdminClient
列出所有 Kafka Consumer:
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);
是否可以以类似的方式列出所有注册的生产者?
最佳答案
与消费者相比,不可能检索此类信息,因为 Kafka 代理不存储有关与其连接的生产者的任何类型的信息。
关于java - 如何列出kafka集群的所有生产者?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60318519/