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

kar*_*ker 8 java apache-kafka kafka-producer-api

我能够列出所有 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);
Run Code Online (Sandbox Code Playgroud)

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

Gio*_*ous 9

相较于消费者,这是不是可以检索这些信息,因为卡夫卡经纪人不存储任何类型的有关连接到他们的生产信息。

  • 这是不正确的,因为生产者将在第一次写入时注册,并且默认情况下它们的 ID 在最后一次写入后 7 天过期。请参阅 https://docs.confluence.io/platform/current/installation/configuration/broker-configs.html#brokerconfigs_transactional.id.expiration.ms。 (2认同)