老师你好，flink cdc捕捉mysql的问题

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

Link_scnu

2021-05-17

第一次启动要全表扫描，写入kafka，然后捕捉动态变化，再写入kafka，怎么保证现在的源端mysql和kafka topic中的数据保持一致啊，cdc捕捉的是全部日志

写回答

1回答

Michael_PK

2021-05-17

扫表的数据到kafka，都是有offset的记录的，知道消费到哪里的

Michael_PK

Link_scnu

你这架构没问题的呢。基本都是这套路：binlog==>中间件==> kafka ==> flink。我们后续课程会用canal中间件

2021-05-17

共2条回复

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

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

1000 学习 · 225 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1