Kafka гарантирует порядок только внутри партиции. Чтобы события одного заказа шли по порядку, у них должен быть одинаковый ключ (order_id) — тогда они попадут в одну партицию.
sottoenable.idempotence=true)А ещё Глобальный порядок — только одна партиция, без параллелизма
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Гарантия. Сообщения в партицию дописываются по порядку, и потребитель читает их в том же порядке. Для сообщений в разных партициях порядок не определён: потребители читают их параллельно.
Как сохранить порядок для сущности — ключ сообщения: продюсер выбирает партицию по хешу ключа, и все события с ключом order:42 идут в одну партицию.
Что может нарушить:
max.in.flight.requests.per.connection > 1 и повторах без идемпотентности второй батч может записаться раньше повторённого первого. Идемпотентный продюсер (по умолчанию с Kafka 3.0) сохраняет порядок при до 5 запросов в полёте;hash(key) % N меняется, новые события ключа идут в другую партицию, пока старые ещё не обработаны;Один верный вариант. Подумайте, потом откройте ответ.
Распределённый append-only лог, партиция как единица масштаба и упорядоченности, ключ и порядок, retention и log compaction, replay.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.