GitHub user vesense opened a pull request:
https://github.com/apache/storm/pull/2518
STORM-2902: Some improvements for storm-rocketmq module
## Brief changelog
* Upgraded RocketMQ version to 4.2.0 which brings improvements and new
features like batch sending
* Imporved retry policy for RocketMQ consumer push mode to avoid data loss
in some scenes
* Batch sending supported for bolt and trident state
* Allow running several consumer instances in one process, that is to say,
different topics in one worker is possible
## Verifying this change
local tests check passed â
apache-rat check passed â
checkstyle check passed â
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vesense/storm rocketmq-improvements
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2518.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2518
----
commit d3232136655647f1968b2b8b0ba22f84f7d1f96c
Author: Xin Wang <xinwang@...>
Date: 2017-12-24T13:27:40Z
STORM-2902: Some improvements for storm-rocketmq module
----
---