我从 KafkaTemplate 实现中看到,无法访问实际的 Kafka Producer。虽然这种 Producer 包装可能很好,但需要 Kafka Producer 中的一些方法,例如metrics()
和partitionsFor(java.lang.String topic)
。在 KafkaTemplate 中,我们可以使用这些相同的方法来包装实际的 Kafka Producer 方法。这可能会在较新的版本中实现吗?我可以实现它并提出拉取请求吗?
问问题
932 次
1 回答
3
根据 Kafka 准则,DefaultKafkaProducerFactory
总是返回相同的生产者,因此调用createProducer
以获取对单个生产者的引用是安全的。
close()
对生产者的调用被忽略。
但是,我已经打开了一个GitHub 问题,以提供从模板访问生产者的权限。
于 2016-09-07T12:57:36.680 回答