CanalRocketMQProducer投递的消息过滤了TRANSACTIONBEGIN和TRAN
在更新目标mysql的时候，我的方案是使用GTID来避免重复插入并避免数据同步回环。因此需要识别TRANSACTIONBEGIN | ROWDATA |...| ROWDATA | TRANSACTIONEND 这样的数据流，并在TRANSACTIONEND的时候统一将上述一批rowdatas按同一个gtid来更新目标mysql。
但通过阅读源码发现CanalRocketMQProducer会将TRANSACTIONBEGIN和TRANSACTIONEND相关event直接过滤了。
这是出于什么考虑呢？ 毕竟rocketmq是支持顺序消费的。
原提问者GitHub用户lueying
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
1
条回答
写回答
-
如果是单topic单分区模式，可以有begin/end的事务消息发送，针对多队列或者多topic模式，事务信息就不好处理
原回答者GitHub用户agapple
2023-05-04 18:04:49赞同 展开评论
相关问答