土法炼钢兴趣小组的算法知识备份

【流式数据处理】Kafka 事务与幂等 Producer

2026-07-01 | database · distributed | #kafka #transactions #idempotent-producer #pid #sequence #transactional-id #read-committed #exactly-once #two-phase-commit

从幂等 producer 的 PID 与 sequence 去重，到事务 producer 的 init/begin/commit/abort 生命周期、__transaction_state 与 read_committed 隔离，讲清 Kafka 3.x 单集群 EOS 边界及其与 Flink checkpoint 的衔接。