Продюсер получает producer id, нумерует пакеты по партициям; брокер отбрасывает повтор с уже записанным номером и не допускает пропусков. Дубли из-за повторов и перестановки исчезают.
А ещё Порядок сохраняется при max.in.flight.requests.per.connection ≤ 5
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Это полезно, когда отправка была успешна, но подтверждение потерялось. Broker видит повтор по producer id (PID) и sequence number и не пишет duplicate record. Ключевая граница: гарантия действует только в пределах одной producer-сессии — после рестарта продюсера брокер выдаёт новый PID, и старые дубли он уже не распознает (от этого защищает только transactional producer с заданным transactional.id или идемпотентность на стороне потребителя).
Один верный вариант. Подумайте, потом откройте ответ.
Запись и сериализация, выбор партиции, батчинг и сжатие, acks и долговечность, идемпотентный producer и транзакции.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto