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.

Sign up for GitHub

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

Jump to bottom

扁平发送RocketMQ出现发送空包现象kafka应该存在同样问题 #1083

Closed
zygfengyuwuzu opened this issue Nov 1, 2018 · 2 comments
Closed

扁平发送RocketMQ出现发送空包现象kafka应该存在同样问题 #1083

zygfengyuwuzu opened this issue Nov 1, 2018 · 2 comments

Comments

@zygfengyuwuzu
Copy link

https://github.com/alibaba/canal/blob/master/server/src/main/java/com/alibaba/otter/canal/rocketmq/CanalRocketMQProducer.java
代码 96行处返回数组，数组中值可能为空，但是下面没有判断，会给mq发送空消息，kafka应该也存在同样问题。

另外一个问题还请大神帮忙回答一下
FlatMessage 这个对象 的属性 data length 什么情况下是大于1的
@rewerma rewerma closed this as completed in b9c4884 Nov 1, 2018
rewerma added a commit that referenced this issue Nov 1, 2018
@rewerma
Merge pull request #1084 from rewerma/master
d3e1ddd 
fix #1083
@rewerma
Copy link
Collaborator

rewerma commented Nov 1, 2018

有发生dml操作data size就会大于1

@agapple agapple mentioned this issue Nov 1, 2018
Closed
@zygfengyuwuzu zygfengyuwuzu mentioned this issue Nov 2, 2018
Closed
@hookover
Copy link

问题仍然存在： kafka消息 = 操作行数 x 2
2019.6.24 cannal v1.1.3

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@rewerma @hookover @zygfengyuwuzu