Теория
Можешь рассказать, как ты организовывал exactly-once доставку сообщений по Kafka?
Для чтения, обработки и записи внутри Kafka результат и смещения потребителя можно фиксировать в одной транзакции.
Читать ответ