私はNodeとKafkaの開発にかなり慣れていません。別のトピックからのメッセージを消費しながら、カフカへのメッセージを生成する必要があるサービスを構築しています。消費のために、私は消費者ストリーム API を使用しています。
ただし、メッセージを生成するために、送信する必要があるメッセージが入力されたリストを監視するバックグラウンド スレッドを基本的に持つことを理解しようとしています。リストには、消費されるデータに基づいてデータが入力されます。
プロデュース用の標準 APIを見ると、「ready」イベントをリッスンする必要があることがわかります。しかし、準備完了イベントの後にどのバックグラウンド プロセスを開始/キックオフする必要がありますか? プロセス/スレッドが、送信する必要があるメッセージのキュー/リストをポーリングして送信し、送信するメッセージが他にもあるかどうかを継続的に確認する必要があります。
ここでワーカースレッドは適切ですか?