spring-kafka - 尽管返回 ListenableFuture，但 KafkaTemplate 会阻塞

Question

我正在使用 spring-kafka 1.1.2。每当我调用返回 ListenableFuture 的 KafkaTemplate 的 send 方法时，它都会阻塞。

查看 KafkaProducer 的源代码，它实际上似乎是这样打算的——我发现对名为“waitOnMetadata”的方法的调用。

我错过了一些明显的东西吗？向 Kafka 发送记录时如何避免阻塞？

Answer 1

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

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

我们打算在此基础上构建 Spring Kafka 的未来版本。