Как я понял, есть два способа:
1. Установка max.in.flight.per.connections = 1, что не позволит отправлять несколько сообщений без подтверждения ответа, но уменьшит пропускную способность
2. Установка
enable.idempotence = true
max.in.flight.per.connection < 5
retries > 0
acks = all
Второй случай мне непонятен, ведь у нас может быть в флай состоянии больше 1 сообщения и если первое не пройдет, то порядок нарушится.
Может кто подскажет куда смотреть, что почитать?
https://kafka.apache.org/documentation/#semantics
Обсуждают сегодня