Debezium 是一個 CDC(Changelog Data Capture,變更數據捕獲)技術的縮寫,它可以將源數據庫 (Source) 的增量變動記錄,同步到一個或多個數據目的 (Sink)。在同步過程中,還可以對數據進行一定的處理,例如分組 (GROUP BY)、多表的關聯 (JOIN) 等。比如把來自 MySQL、PostgreSQL、Oracle、Microsoft SQL Server 和許多其他數據庫的更改實時流式傳輸到 Kafka 中。 Debezium 為變更日志提供了統一的格式結構,並支持使用 JSON 和 Apache Avro 序列化消息。
REFER:
https://debezium.io/documentation/
https://github.com/debezium/debezium
https://pulsar.apache.org/docs/en/io-cdc-debezium/
https://mp.weixin.qq.com/s/_67XXbPAawegCP08W8FHIQ
https://wufc.info/post/streaming/debezium/
https://mp.weixin.qq.com/s/q_O6NUYFrtibG_ytuRHtgQ