跨schema实时同步数据

你说的方案可以啊,
cdc → kafka → java → N tables
或者 CDC → kafka → Flink → N tables

结构不一样,也没问题的,只要数据能填充