Kafka Exactly Once

Exactly once

producer client端，打开enable.idempotence=true
每个batch messages包含一个seqNo。
broker把该信息持久化到replicated log，并进行dedupe

Transaction

actomic writes across multiple partitions