Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

canal监听mysql binlog后发送消息到rocketmq,我使用一个update语句一次性 更改了四条数据,但是发送了两条消息到mq中,每条mq消息包含了两个数据 #5360

Open
liukai0714 opened this issue Dec 17, 2024 · 2 comments

Comments

@liukai0714
Copy link

Question

canal监听mysql binlog后发送消息到rocketmq,我使用一个update语句一次性 更改了四条数据,但是发送了两条消息到mq中,每条mq消息包含了两个数据。
数据库binlog格式:ROW

以下是canal的部分配置:

canal.properties:
canal.mq.flatMessage=true
canal.instance.binlog.format = ROW
canal.instance.binlog.image = FULL,MINIMAL,NOBLOB

instance.properties
canal.mq.topic=topic_canal
canal.mq.partition=0
canal.mq.partitionsNum=4

@liukai0714
Copy link
Author

使用的是这个版本 canal.deployer-1.1.8-SNAPSHOT

@liukai0714
Copy link
Author

正常是应该要发送四条消息到MQ吧?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant