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

【流式数据处理】Debezium 与 Change Data Capture

2026-07-01 | database · distributed | #debezium #cdc #kafka-connect #mysql #postgresql #binlog #snapshot #schema-history

从 Debezium 变更事件信封（op、before/after、source）入手，拆解 snapshot 与 streaming 两阶段、Kafka Connect 的 connector task 与 offset/schema history 主题，并说明引擎侧如何保证主键顺序与幂等，衔接 lakehouse 第 19 章 upsert 入湖。