Flink CDC 用 Oracle CDC 实时同步数据到 Elasticsearch
一、整体架构与 Demo 思路本 Demo 会启动 3 个容器:
Oracle 19c:作为上游业务库;
Elasticsearch 7.6.0:存储 Flink 处理后的结果;
Kibana 7.6.0:可视化 Elasticsearch 数据。
数据流非常简单直观:
Oracle PR

