请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

正在回答

1回答

这个上下文描述下,不太明白你的意思。

0 回复 有任何疑惑可以回复我~
  • 提问者 zengchen #1
    flink cdc 同步的时候,如果上游修改了字段类型,下游可以自动修改字段类型吗?还有新增字段,删除字段这类操作
    然后我可以在一个 flink cdc 任务里面把整个数据库的所有表都同步到下游的数据库里吗?
    回复 有任何疑惑可以回复我~ 2023-05-09 09:33:12
  • Michael_PK 回复 提问者 zengchen #2
    “如果上游修改了字段类型,下游可以自动修改字段类型吗”这个使用官方的flink cdc我还真没测试过,你可以动手试试看。我们的一套是自己实现的,内在机制其实不难,就是监听binlog日志,监听ddl的更改,收到ddl的语句我们会去修改表结构来完成这个逻辑。新增字段,删除字段同理
    
    
    “我可以在一个 flink cdc 任务里面把整个数据库的所有表都同步到下游的数据库里”这个操作我觉得其实在生产上不会这么做的,因为你的业务不太可能会涉及所有的表,而是库中的N个表,这个就挑出来写到代码中就可以了
    回复 有任何疑惑可以回复我~ 2023-05-11 19:58:41
  • 提问者 zengchen #3
    非常感谢!
    回复 有任何疑惑可以回复我~ 2023-05-12 15:37:55
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信