老师，想问下用flink cdc捕捉到数据存到kafka，再从kafka发送到下游

来源：1-1 课前须知，这里有你需要了解得一切

Link_scnu

2021-05-18

问题：无论是deezium ，还是cdc connectors存到kafka中的都是binlog日志，实时动态操作日志，我要发送到下游mysql或者hive，那么我怎么消费过滤获取到最新的，再异步发送到各个下游
图片描述

写回答

1回答

Michael_PK

2021-05-19

数据到kafka，然后flink对接kafka数据，这里面必然有offset的。

实时数仓就可能有业务数据的变更的，下游的肯定有支持upsert的操作

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1000 学习 · 225 问题

相似问题

回答 1

回答 2

回答 1

回答 1

回答 1