Kafka Exactly Once

Exactly once

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

Transaction

actomic writes across multiple partitions

Share Comments