问题1:大佬请问这个事务信息怎么从Flink CDC datastream api中拿到呢,debezium的事务属性是开启了的?
问题2:是这个吗,这个开启了的
开启这个后能获取到如下数据:
但是获取不到这个:
目前就只能获取到这个参数
这个找到解决方案了,需要修改一点源码才行,目前事务信息被过滤掉了
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
回答1:你看看有个配置能不能拿到,拿到也需要自己序列化binlog,有个配置,在官网mysql cdc的最后面 回答2:这个参数我开了。。任务会直接报错。。。。也不知道是啥原因,我没试过这个,你需要测试看,要看报的什么错,此回答整理自钉群“Flink CDC 社区”