You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/04/11 09:00:43 UTC
[GitHub] [rocketmq] fengxueyun opened a new issue, #4149: send batch message
fengxueyun opened a new issue, #4149:
URL: https://github.com/apache/rocketmq/issues/4149
send batch orderLyMessage
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] lwclover commented on issue #4149: send batch message
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4149:
URL: https://github.com/apache/rocketmq/issues/4149#issuecomment-1095770711
> send batch orderLyMessage
The batch sends to the same queue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] fengxueyun commented on issue #4149: send batch message
Posted by GitBox <gi...@apache.org>.
fengxueyun commented on issue #4149:
URL: https://github.com/apache/rocketmq/issues/4149#issuecomment-1095921716
I want to send messages in batches, and implement queue segmentation according to a certain attribute, so as to realize the implementation order of the same value of the attribute, that is, the sequential consumption when consuming
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] lwclover commented on issue #4149: send batch message
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4149:
URL: https://github.com/apache/rocketmq/issues/4149#issuecomment-1096547854
You can use the solution @panzhi33 mentioned. In the batch, You can not have delay messages.
In addition, if you want to guarantee absolute order when consuming, you need to implement MessageListenerOrderly,
There is a risk use MessageListenerOrderly that if one message is not consumed, it will block the consumption of subsequent messages.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] panzhi33 commented on issue #4149: send batch message
Posted by GitBox <gi...@apache.org>.
panzhi33 commented on issue #4149:
URL: https://github.com/apache/rocketmq/issues/4149#issuecomment-1096318803
org.apache.rocketmq.client.producer.DefaultMQProducer#send(java.util.Collection<org.apache.rocketmq.common.message.Message>, org.apache.rocketmq.common.message.MessageQueue)
See if this method meets your needs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] panzhi33 closed issue #4149: send batch message
Posted by GitBox <gi...@apache.org>.
panzhi33 closed issue #4149: send batch message
URL: https://github.com/apache/rocketmq/issues/4149
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org