Что делали с отставанием consumer'а при перевыкатке?

При перевыкладке сохраняйте неподтверждённый прогресс и обеспечивайте достаточно мощности для догоняния очереди. Важно контролировать lag и время ребалансировки, а не скрывать отставание.

Graceful shutdown даёт завершить текущую обработку, но авария всё равно требует безопасного повтора. Оцените скорость поступления и обработки, retention и нагрузку на БД. Массовая одновременная остановка всех consumers может создать пик lag, поэтому порядок rollout тоже важен.