
7/26/2017 · Ben Stopford
What this post added
This post details how Kafka transactions enable exactly-once processing semantics for read-process-write cycles in stream processing applications. It covers atomic multi-partition writes, zombie fencing using transactional.ids, and how consumers read transactional messages. The implementation details include the Transaction Coordinator and Transaction Log, and the data flow for producer-coordinator interaction, transaction initiation, and message production within transactions. It also touches upon the use of idempotence for send-side deduplication.