問題タブ [node-worker-threads]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
node.js - node-rdkafka を使用してワーカー スレッドでメッセージを生成する
私はNodeとKafkaの開発にかなり慣れていません。別のトピックからのメッセージを消費しながら、カフカへのメッセージを生成する必要があるサービスを構築しています。消費のために、私は消費者ストリーム API を使用しています。
ただし、メッセージを生成するために、送信する必要があるメッセージが入力されたリストを監視するバックグラウンド スレッドを基本的に持つことを理解しようとしています。リストには、消費されるデータに基づいてデータが入力されます。
プロデュース用の標準 APIを見ると、「ready」イベントをリッスンする必要があることがわかります。しかし、準備完了イベントの後にどのバックグラウンド プロセスを開始/キックオフする必要がありますか? プロセス/スレッドが、送信する必要があるメッセージのキュー/リストをポーリングして送信し、送信するメッセージが他にもあるかどうかを継続的に確認する必要があります。
ここでワーカースレッドは適切ですか?