Партиция для ключа — hash(key) % N. Сменили N — новые сообщения ключа идут в другую партицию, а старые ещё могут обрабатываться: порядок по ключу на переходе нарушается.
А ещё Число партиций закладывают с запасом при создании
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Уже записанные сообщения остаются на местах, а новые с тем же ключом могут уйти в другую партицию, и относительный порядок между старыми и новыми записями одного ключа теряется. Для сценариев, где порядок по ключу критичен — например, последовательность изменений состояния заказа, — это может означать некорректную обработку. Отсюда практический вывод: число партиций задаёт запас масштабируемости и его планируют заранее, ведь уменьшить его вообще нельзя. Если увеличение необходимо, безопасные пути такие: создать новый топик с нужным числом партиций и мигрировать потребителей, либо выбрать момент, когда обработка старых сообщений заведомо завершена.
Один верный вариант. Подумайте, потом откройте ответ.
Consumer lag и его причины, ребаланс и безопасный commit, poison-сообщения, ZooKeeper → KRaft, schema evolution, изменения partitions и ключевые метрики.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto