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

[ROCKETMQ-219] Add batch example #112

Closed
wants to merge 1 commit into from

Conversation

dongeforever
Copy link
Member

@coveralls
Copy link

coveralls commented Jun 7, 2017

Coverage Status

Coverage decreased (-0.05%) to 38.628% when pulling d1db5af on dongeforever:ROCKETMQ-219 into 80791b6 on apache:develop.

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

public class SplitBatchProducer {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What about adding comments to this sample class to explain what it is going to demonstrate, since this example seem to be a little complicated.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good to add a concise explanation why we should split when sending in batch. That is, total message size of messages in a batch cannot exceed 1 mega bytes on default.

@lizhanhui
Copy link
Contributor

Overall +1

@zhouxinyu
Copy link
Member

+1, LGTM~

@vongosling
Copy link
Member

+1

@dongeforever
Copy link
Member Author

@zhouxinyu Thanks

asfgit pushed a commit that referenced this pull request Jun 22, 2017
@ranqiqiang
Copy link
Contributor

rocketmq version 4.5 , SimpleBatchProducer 会出现:
“the message is illegal, maybe msg body or properties length not matched. msg body length limit 128k, msg properties length limit 32k.”
看demo 数据量很小的啊,版本4.3 就不会出现,是broker 什么设置不对吗?

lizhanhui pushed a commit to lizhanhui/rocketmq that referenced this pull request Jun 25, 2019
lizhanhui pushed a commit to lizhanhui/rocketmq that referenced this pull request Jun 25, 2019
lizhanhui pushed a commit to lizhanhui/rocketmq that referenced this pull request Jun 25, 2019
lizhanhui pushed a commit to lizhanhui/rocketmq that referenced this pull request Jun 25, 2019
JiaMingLiu93 pushed a commit to JiaMingLiu93/rocketmq that referenced this pull request May 28, 2020
JiaMingLiu93 pushed a commit to JiaMingLiu93/rocketmq that referenced this pull request May 28, 2020
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

Successfully merging this pull request may close these issues.

None yet

7 participants