Hi folks, Now the improvements for RocketMQ-Storm has been merged into master.
Here is the latest state of rocketmq streaming integration: Module Status * RocketMQ-Storm *Available* * RocketMQ-Spark *Available, improvements patch to be merged.* * RocketMQ-Flink *Available* * RocketMQ-Serializer(including JSON, Apache Avro) *Available, to be merged.* Some new modules on the road: * RocketMQ-SQL https://issues.apache.org/jira/browse/ROCKETMQ-357 * RocketMQ-Beam(Beam IO) Recently, I'm working on the RocketMQ *SQL*. Hope the initial version can be released ASAP. Anybody who is interested in please join me. Thanks, Xin Wang