@debezium / 博客 RSS 訂閱

Dec 28 2025

信息小飛俠 - Flink 1.11.1:flink CDC Debezium自定義修改debezium-json格式

Flink CDC系列之：Kafka的Debezium JSON 結構定義類DebeziumJsonStruct 這是一個 Debezium JSON 結構定義類，使用枚舉來定義 Debezium JSON 格式的字段結構和位置信息。 類概述 public class DebeziumJsonStruct 這個類

Flink CDC系列 , Debezium JSON , 結構定義類 , debezium , kafka , 前端開發 , Javascript

收藏 評論

Jul 05 2023

javalover - 開源數據集成平台SeaTunnel：MySQL實時同步到es

一、前言 最近，項目有幾個表要從 MySQL 實時同步到 另一個 MySQL，也有同步到 ElasticSearch 的。 目前，公司生產環境同步，用的是 阿里雲的 DTS，每個同步任務每月 500多元，有點小貴。 其他環境：MySQL同步到ES，用的是 CloudCanal，不支持 數據轉換，添加同步字段比較麻煩，社區版限制5個任務，不夠用；MySQL同步到MySQL，用的是 debez

數據同步 , 同步 , canal , 實時 , debezium

收藏 評論