Flink CDC 2.0 實現原理剖析

Flink CDC 2.0 實現原理剖析

FLIP-27 旨在解決SourceFunction中存在的幾個痛點:split 的發現邏輯(work discovery)和實際讀取資料的邏輯耦合在SourceFunction和DataStream介面中,導致 source 實現的複雜性...

2022-03-05