我可以列出所有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);
有没有可能以类似的方式列出所有注册的生产商?
1条答案
按热度按时间hvvq6cgz1#
与消费者不同的是,由于Kafka经纪人不存储与他们有关的生产者的任何信息,因此无法检索此类信息。