在mysql cdc出来,通过data stream写入kafka,但没有操作的flag,在哪配置?

我有个疑问,在从mysql cdc出来,通过data stream写入kafka,目前kafka消息里面有数据,但是没有操作的flag(insert、update、delete), 这个是在哪里配置呢?

展开
收起
滴滴滴~ 2023-03-21 14:16:20 225 分享 版权
1 条回答
写回答
取消 提交回答
  • op这个字段就是的 C 就是插入 U就是更新,D是删除。此答案整理自钉群“Flink CDC 社区”

    2023-03-21 16:39:19
    赞同 展开评论

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

收录在圈子:
+ 订阅
还有其他疑问?
咨询AI助理