THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
config | current default value | proposed default value |
---|---|---|
enable.idempotence | false | true |
acks | 1 | all |
max.in.flight.requests.per.connection | 5 | 2 |
retries | 0 | MAX_INT |
There will be no other publicly visible changes required.
The changes above would guarantee exactly once, in order delivery per partition for topics with replication-factor >= 2
, and assuming that the system doesn't suffer multiple hard failures or concurrent transient failures.
Proposed Changes
Code changes
...