nifi-flink

数据抽取方落表数据（方便指标做double check比对）

NIFI Binlog同步DML数据

每张表配置一个topic实时同步

过滤清洗

多流表join

聚合、窗口计算

业务方原始数据表

FlinkSourceKafkaN

Nifi同步层

实时指标落库

Flink计算层

FlinkSourceKafka02

DistributedMapCacheServer数据缓冲通道

Nifi发送表数据变动kafka消息

(每张表对应一个kafkaTopic)

.....

实时数据宽表层

FlinkSourceKafka01