私はカフカ 0.8.2 を使用しています。ドキュメントが言うように:
batch.num.messagesは次を指定します。
非同期モードの使用時に 1 回のバッチで送信するメッセージの数。プロデューサは、この数のメッセージを送信する準備ができるか、または queue.buffer.max.ms に達するまで待機します。
request.required.acksは、ブローカーによるリクエストの確認を制御します。
Kafka ブローカーはこの確認応答をどのように送信するのだろうか、バッチに対して、または個々のメッセージごとに ACK を送信するのでしょうか?