从 KafkaTemplate 获取主题元数据

Get topic metadata from KafkaTemplate

我从 KafkaTemplate 实现中看到,无法访问实际的 Kafka Producer。虽然这个 Producer 包装可能很好,但 Kafka Producer 中有一些方法是需要的,比如 metrics()partitionsFor(java.lang.String topic)。 在 KafkaTemplate 中,我们可以使用这些相同的方法来包装实际的 Kafka Producer 方法。 这可能会在新版本中实现吗? 我可以实施它并提出拉取请求吗?

根据 Kafka 准则,DefaultKafkaProducerFactory 总是 returns 同一个生产者,因此调用 createProducer 获取对单个生产者的引用是安全的。

对生产者的调用 close() 被忽略。

但是,我已经打开了一个 GitHub Issue 以提供从模板访问制作人的权限。