CDC ChangeLog Stream 实时流入 CLICKHOUSE 最佳姿势

水滴

2022-10-25

通过batch option 可以支持攒批写入，避免频繁写入造成的性能下降问题；同时通过batchTime option兼顾数据实时性 将Flink的Retract Stream（回撤流）、Upsert Stream（更新-插入流）含有状态标记的数据流，写入到ClickHouse的 CollapsingMergeTree引擎表中。