Kafka transactions

EN: Kafka transactions

Функциональность Kafka (представлена в KIP-98), позволяющая producer атомарно записывать в несколько партиций и фиксировать offset consumer-а в рамках той же транзакции, обеспечивая exactly-once обработку. Брокер отслеживает состояние каждого producer через transactional ID; consumer-ы с isolation.level=read_committed видят только сообщения из зафиксированных транзакций.