采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
这个上下文描述下,不太明白你的意思。
flink cdc 同步的时候,如果上游修改了字段类型,下游可以自动修改字段类型吗?还有新增字段,删除字段这类操作 然后我可以在一个 flink cdc 任务里面把整个数据库的所有表都同步到下游的数据库里吗?
“如果上游修改了字段类型,下游可以自动修改字段类型吗”这个使用官方的flink cdc我还真没测试过,你可以动手试试看。我们的一套是自己实现的,内在机制其实不难,就是监听binlog日志,监听ddl的更改,收到ddl的语句我们会去修改表结构来完成这个逻辑。新增字段,删除字段同理 “我可以在一个 flink cdc 任务里面把整个数据库的所有表都同步到下游的数据库里”这个操作我觉得其实在生产上不会这么做的,因为你的业务不太可能会涉及所有的表,而是库中的N个表,这个就挑出来写到代码中就可以了
非常感谢!
登录后可查看更多问答,登录/注册
轻松入门大数据(2):玩转Flink,打造湖仓一体架构
259 4
255 1
279 1
261 1
74 1