5.3. 順序付き配信

メッセージは 1 度だけ配信されるため、べき等プロデューサーは重複を回避します。障害発生時でも配信の順序が維持されるように、ID とシーケンス番号がメッセージに割り当てられます。データの一貫性を保つために acks=all を使用している場合は、順序付けられた配信に冪等性を有効にすることが妥当です。デフォルトでは、プロデューサーに対して冪等性が有効になっています。冪等性を有効にすると、メッセージの順序を維持するために、進行中の同時リクエストの数を最大 5 に設定できます。

# ...
enable.idempotence=true 

max.in.flight.requests.per.connection=5 

acks=all 

retries=2147483647 

# ...

パフォーマンスコストのために acks=all を使用せず、冪等性を無効にすることを選択した場合は、進行中の (未確認の) 要求の数を 1 に設定して、順序を維持します。そうしないと、Message-A が失敗し、Message-B がブローカーに書き込まれた後にのみ成功する可能性があります。

# ...
enable.idempotence=false 

max.in.flight.requests.per.connection=1 

retries=2147483647
# ...