問題タブ [reactive-kafka]

質問する

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.

55 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
91 参照

apache-kafka - すべてのメッセージを Kafka に送信する前にリアクティブ プログラムが早期に終了する

これは、以前のリアクティブ カフカの問題 (リアクティブ カフカにデータのフラックスを送信している間の問題) に続く質問です。

リアクティブなアプローチを使用して、いくつかのログ レコードを kafka に送信しようとしています。これは、リアクティブ カフカを使用してメッセージを送信するリアクティブ コードです。

そのため、 が存在する場合でも、Thread.sleep(0, 5);すべてのメッセージを kafka に送信しない場合があり、プログラムは早期に SUCCESS メッセージを出力します ( log.info("[SUCCESS]: {} records sent to the topic: '{}'", sentCount, topic);)。この問題を解決する具体的な方法はありますか。たとえば、何らかのコールバックを使用して、スレッドがすべてのメッセージが正常に送信されるまで待機するようにします。

私は春のコンソールアプリケーションを持っていて、固定レートでスケジューラを介して ExecuteQuery を実行しています。


12345678910