Что фиксируется в транзакции при обработке Kafka-сообщения?

В транзакции БД фиксируют бизнес-изменения и признак обработки сообщения; Kafka offset подтверждают после успешной фиксации, учитывая возможность повторной доставки.

При обработке с записью во внешнюю БД Kafka-транзакция сама по себе не включает эту базу. В одной транзакции БД можно сохранить результат и уникальный идентификатор сообщения либо позицию обработки. При сбое после commit БД, но до commit offset, сообщение придёт повторно; повтор должен безопасно распознаться. В сценарии Kafka → Kafka транзакционный producer может атомарно записать выходные сообщения и offsets потребителя.

Источник: Документация Apache Kafka.