問題タブ [reactive-streams]
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.
microservices - リアクティブ ストリーム Kafka ストリーム HTTP アクターへのファンアウト
私は Akka Streaming とリアクティブ ストリーミングを初めて使用します。質問があります。残りの API がメッセージを受信して Kafka Bus にドロップし、Kafka ストリーミング コンシューマーがメッセージを最大数に集約することは可能ですか。タイム ウィンドウと答えを再実行しますか?
そのようなシステムをどのように実装しますか？またはどこから始めますか？
ありがとう
scala - ReactiveKafka のパフォーマンスの問題
akka-reactive kafka私は最近、消費者のパフォーマンスを向上させるために、従来の kafka-clients Java から移行しました。の最新バージョンを使用していakka-reactive-kafka (0.16)ます。私のフローは非常に単純ですread from kafka then group by batch then process by batch then commit。少しベンチマークを行いましたが、約で非常に悪い結果が得られました2 000 msg / sec。ベンチについては、kafka-producer-perf-test.sh.
scala コード + ログの下:
[
参考までに、このコードを EC2 t2 ミディアム マシンで実行し、Python で記述された kafka クライアントを使用して、5000 メッセージ/秒のレートを得たので、リアクティブ API の使用方法で何か間違ったことをしていると思いますが、見つかりません何。react-kafka-benchmarkに関するこのブログを読むと、スループットが向上するはずです!