отправки?
Мой дев стенд использует Kafka 2.7 с 3 брокерами и 12 партициями на каждый топик.
Продюсеры выставлены с Acks WaitForLocal (1).
Сообщения по одному и тому же Key отправляются по той же партиции.
Допустим, у меня идет отправка сообщений 1, 2, 3 в таком же порядке. Но записываются они в порядке 2, 3, 1.
Может ли на это влиять acknowledgement level, к примеру, если я выставлю WaitForAll (-1)?
Заранее огромное спасибо за помощь.
У них у всех точно один и тот же ключ?
Да, у всех один и тот же ключ. Используется Hash Partitioner. Заранее извиняюсь за приложенную ссылку на изображение если это не приятно в данной группе. https://ibb.co/4WwLFXR
Судя по картинке и содержание одинаковое
Порядок может поменяться, если max.in.flight.requests.per.connection > 1 и retries > 1. Судя по доке (но зависит от клиента, который используете), по умолчанию там как раз такие значения, которые могут приводить к реордерингу. Сами по себе acks на порядок не влияют. Влияют попытки продюсера самостоятельно переотправить сообщения, если возникшая ошибка retryable
Обсуждают сегодня