KafkaTemplate 块虽然返回一个 ListenableFuture

Question

我正在使用 spring-kafka 1.1.2。每当我调用 KafkaTemplate 的发送方法返回一个 ListenableFuture 时，它​​就会阻塞。

查看 KafkaProducer 的源代码，它实际上似乎是这样的 - 我发现对名为 "waitOnMetadata".

的方法的调用

我是不是遗漏了什么明显的东西？向Kafka发送记录时如何避免阻塞？

Answer 1

kafka生产者代码在调用线程上被调用；可听的未来是收到来自卡夫卡的确认消息已收到。

有一个 reactor-kafka 项目，可能会有帮助。

我们打算以此为基础开发 Spring Kafka 的未来版本。