安定しているが調整可能な出力で Apache Kafka プロデューサーを作成する最良の方法は何ですか。
例:プロデューサーは、一定の 1000 メッセージ/秒をブローカーに送信する必要があります。ランタイム中、出力は 10 または 10000 メッセージ/秒に調整できる必要があります。
1 つの方法として、1 秒ごとに実行されるスケジューラを設定し、事前定義された量のメッセージをバッチで送信する方法があります。
追加:このプロデューサはパフォーマンス テスト フレームワークの一部である必要があるため、送信する必要があるメッセージの量は非常に多くなります。非常に高い負荷をどのように処理しますか? そのためにAkkaを使用することは有益でしょうか?
ターゲット言語は Scala ですが、どの言語のサンプル コードも大歓迎です。