0
batch.sizeを小さくすると、プロデューサでメッセージを送信するオーバーヘッドが増え、同時にスループットが低下し、メモリを大量に消費します。このサイズが負荷に応じて動的になる可能性のあるソリューションはありますか？kafkaプロデューサでbatch.sizeを動的にするにはどうすればよいですか？
A
答えて
0
以前のプロデューサを停止して新しいプロデューサを開始した場合のみ。プロデューサオブジェクトは、メッセージを送信する前にすべてのプロパティを必要とします。ジョブの途中でプロパティを変更することはできません。
+0
だから、このプロパティを設定するためのベストプラクティスは何ですか？ –
+0
この問題に対処する2つの視点があります：レイテンシとスループット。あなたは一度にどちらかを持つことはできません。最大のスループットを達成したい場合や、最大遅延を設定する場合は、linger.ms = 0と設定すると、linger.msを使用できます。 – subzero
0
linger.msとbatch.sizeプロパティを組み合わせて使用できます。 batch.sizeを5242880（5 MB）、linger.msを10 msに設定した場合は、次に、プロデューサは、バッチサイズが満たされるか、または残存時間に達するまで待つ。
linger.msプロパティの詳細については、公式ドキュメントを参照してください。
関連する問題
- 1. プロデューサをアクタに接続するにはどうすればよいですか？
- 2. Kafka：クライアントログを有効にするにはどうすればよいですか？
- 3. メタタグを動的に含めるにはどうすればよいですか？
- 4. DefaultMessageListenerContainerが自動的に起動しないようにするにはどうすればよいですか？
- 5. 動的URLを作成するにはどうすればよいですか？
- 6. 動的ルートを作成するにはどうすればよいですか？
- 7. 動的オブジェクトをシリアル化するにはどうすればよいですか？
- 8. ボタンが自動的に押されないようにするにはどうすればよいですか？
- 9. プロデューサとコンシューマに両方の方法で通信するにはどうすればよいですか？
- 10. 動的ナビゲーションで動的コンテンツを作成するにはどうすればよいですか？
- 11. 動的アイテムを動的に生成するにはどうすればよいですか？
- 12. 動的データに動的HTMLを追加するにはどうすればよいですか？
- 13. 動的タグに動的ドロップダウンリストを挿入するにはどうすればよいですか？
- 14. C＃コンソールアプリケーションが自動的に閉じないようにするにはどうすればよいですか？
- 15. UIButtonをプログラム的に動かすにはどうすればいいですか？
- 16. Kafkaを使用してSpring Cloud Stream内に冪等元のプロデューサを設定するにはどうすればよいですか？
- 17. ABAPで段階的に動的な構造を作成するにはどうすればよいですか？
- 18. OpenSSLから動的および静的ライブラリを生成するにはどうすればよいですか？
- 19. AWSでマシンを自動的に起動するにはどうすればよいですか？
- 20. 自動レイアウトiOSでフォントサイズを動的に変更するにはどうすればよいですか？
- 21. 動的オブジェクトのメソッドを動的に呼び出すにはどうすればよいですか？
- 22. JScrollPaneが自動的にスクロールしないようにするにはどうすればいいですか？
- 23. 動的ルートを追加するにはどうすればいいですか？
- 24. Apache Kafkaでこれを実現するにはどうすればよいですか
- 25. Apache Flume Kafkaプロデューサ - partition_id/keyを動的に生成
- 26. 起動時に自動的にresqueワーカーを作成するにはどうすればよいですか？
- 27. 起動時にPowerShellスクリプトを自動的に実行するにはどうすればよいですか？
- 28. Ubuntuの起動時にサービスを自動的に開始するにはどうすればよいですか？
- 29. サブジョブまたはサブフローを動的に起動するにはどうすればよいですか？
- 30. AngularJSで動的に作成されたドロップダウンオプションを削除するにはどうすればよいですか？
https://issues.apache.org/jira/browse/KAFKA-1026 –
着信負荷をどのように予測しますか？過去1分間の着信負荷は、次の/未来の分と同じではない可能性があります。 –