Что произойдёт, если consumer Kafka упадёт после обработки сообщения, но до коммита offset?

Kafka хранит offset отдельно от сообщений.

Если:

1. consumer получил сообщение;

2. обработал его;

3. упал до коммита offset;

Kafka считает сообщение неподтверждённым.

После перезапуска:

• consumer прочитает это сообщение снова;

• возможна повторная обработка.

Именно поэтому:

• нельзя полагаться на “ровно один раз”;

• бизнес-логика должна быть идемпотентной;

• часто используют:

  • idempotency key,

  • таблицу обработанных событий,

  • outbox/inbox паттерны.

Вывод: повторная доставка — норма, а не исключение.