two-phase-commit 标签归档

共 3 篇文章 · 返回首页

【流式数据处理】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 的衔接。

【流式数据处理】两阶段提交与端到端 Exactly-Once

2026-07-01 | database · distributed | #flink #two-phase-commit #exactly-once #kafka-transactions #iceberg-sink #GenericTwoPhaseCommitSink #checkpoint #notifyCheckpointComplete

拆解 Flink GenericTwoPhaseCommitSink 协议：preCommit 进 checkpoint、commit 挂 notifyCheckpointComplete；对照 Kafka 事务 sink、JDBC 与 Iceberg 2PC 落点，以及 commit 前/后崩溃与重复 commit 的幂等边界——与 lakehouse/11 CAS、lakehouse/19 入湖侧对读，不重复表格式全文。

【PG 内核】事务与子事务：Savepoint 的 TransactionState 栈和 2PC 的状态文件

2026-06-16 | database · kernel | #postgresql #pg-kernel #transaction #subtransaction #savepoint #two-phase-commit #2pc #transstate #xid #wraparound #xact

拆解 PostgreSQL 事务系统的三层结构：事务状态机 TransState 的状态转换路径、子事务（savepoint）的 TransactionState 栈与 ResourceOwner 嵌套管理、两阶段提交（2PC）的 WAL 记录与 pg_twophase 状态文件格式、事务 ID 分配的 xidStopLimit/xidWrapLimit 防线。附带 2PC 泄露的排查 SQL 和子事务栈过深的故障案例。