apache kafkaからのメッセージを消費するために、春の統合でカスタム受信チャネル アダプターを実装しようとしています。春の統合の例に基づいて、MessageSource インターフェイスを実装するクラスを作成し、kafka から消費されたメッセージを返す receive() メソッドを実装する必要があることがわかりました。ただし、 kafka のコンシューマーの例に基づいて、KafkaStream のメッセージ イテレーターは BlockingQueue によって支えられています。そのため、キューにメッセージがない場合、スレッドはブロックされます。
このメソッドは、消費するものがあるまでブロックされる可能性があるため、 receive() メソッドを実装する最良の方法は何ですか?
より一般的な意味では、消費する準備ができるまでブロックするストリーミング メッセージ ソース用のカスタム インバウンド チャネルを実装するにはどうすればよいでしょうか?