KafkaTemplateブロックはListenableFutureを返しますが

Question

私はspring-kafka 1.1.2を使用しています。 ListenableFutureを返すKafkaTemplateのsendメソッドを呼び出すたびにブロックされます。

KafkaProducerのソースコードを見ると、実際にはそのように意図されているようです - 「waitOnMetadata」という名前のメソッドが呼び出されました。

明らかなものがありませんか？カフカにレコードを送信するときにどうやってブロックするのを避けることができますか？

Answer 1

カフカプロデューサコードは、呼び出しスレッドで呼び出されます。聞くことができる未来は、メッセージが受信されたというカフカからの確認を受け取ることです。

reactor-kafkaプロジェクトがあります。これは役に立ちます。

今後のバージョンのSpring Kafkaをベースにしたいと考えています。