SB
Прочитал статейку, по поводу гарантии очередности сообщений в партиции. max.in.flight.requests.per.connection=1 решеает проблему нарушения порядка в случае ретраев, но снижает пропускную способность. И как решение предлагается выставить такие настройки:
You can also set enable.idempotence=true without the need to decreasing max.in.flight.requests.per.connection but you need to adjust other settings according to documentation:
Note that enabling idempotence requires max.in.flight.requests.per.connection to be less than or equal to 5, retries to be greater than 0 and acks must be ‘all’.
up
