カフカプロデューサーはレプリカの存在下でクォータレートでデータを供給できますか？

Question

私はクライアントIDが "p1"で、クォータが50MBpsのクライアントに属するカフカプロデューサーを持っています。

"bin/kafka-producer-perf-test.sh"を使用して私のプロデューサのパフォーマンスをテストしました。レプリカなしでパーティションに書き込むとき、50 MBpsに近いスループットを得ることができました。

3つのレプリカを持つパーティションで同じ実験を試みました。しかし今回は、スループットが30 MBpsに低下しました。

私の質問は、kafkaはプロデューサーがレプリカの存在下でも50 MBpsのスループットを得られるようにすべきですか？システムには何も実行されていないので、なぜこれが起こっているのかわかりません。

Answer 1

プロデューサのacks設定を変更しましたか？あなたの説明から、acksはallに設定されていると思われます。したがって、送信されたデータがスループットに影響を与える3つのブローカ間で複製されるまで、プロデューサは待機します。 acksを変更しない場合は、0に設定してください。プロデューサは、スループットに影響するかどうかを確認するために、サーバーからの肯定応答をまったく待つことはありません。