Карточка Senior Kafka обновлено

Exactly-once в Kafka

Вопрос

Как устроен exactly-once в Kafka и где его границы?

Попробуйте сами

Ответьте про себя или вслух, потом откройте ответ и сверьтесь.

Показать ответ и разбор

Коротко

Идемпотентный продюсер убирает дубли ретраев. Транзакции атомарно пишут в несколько партиций и коммитят оффсеты чтения (read-process-write).

Ответ

Идемпотентный продюсер убирает дубли ретраев. Транзакции атомарно пишут в несколько партиций и коммитят оффсеты чтения (read-process-write). Консьюмеры с isolation.level=read_committed не видят незавершённых транзакций. Граница: гарантия действует внутри Kafka; запись во внешнюю систему требует идемпотентного приёмника.

Разбор

Идемпотентный продюсер убирает дубли ретраев. Транзакции атомарно пишут в несколько партиций и коммитят оффсеты чтения (read-process-write). Консьюмеры с isolation.level=read_committed не видят незавершённых транзакций. Граница: гарантия действует внутри Kafka; запись во внешнюю систему требует идемпотентного приёмника.

Ответьте сами, а не прочитайте

В тренажёре вопрос попадёт в повторения и вернётся, когда начнёт забываться. Плюс билеты с зачётом: 20 вопросов, не больше 2 ошибок.