从 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 以提供从模板访问制作人的权限。
我从 KafkaTemplate 实现中看到,无法访问实际的 Kafka Producer。虽然这个 Producer 包装可能很好,但 Kafka Producer 中有一些方法是需要的,比如 metrics()
和 partitionsFor(java.lang.String topic)
。
在 KafkaTemplate 中,我们可以使用这些相同的方法来包装实际的 Kafka Producer 方法。
这可能会在新版本中实现吗?
我可以实施它并提出拉取请求吗?
根据 Kafka 准则,DefaultKafkaProducerFactory
总是 returns 同一个生产者,因此调用 createProducer
获取对单个生产者的引用是安全的。
对生产者的调用 close()
被忽略。
但是,我已经打开了一个 GitHub Issue 以提供从模板访问制作人的权限。