2

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

4

1 回答 1

3

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

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

但是,我已经打开了一个GitHub 问题,以提供从模板访问生产者的权限。

于 2016-09-07T12:57:36.680 回答