Major Description
Apache Beam is an open source, unified model for defining both batch and streaming data-parallel processing pipelines.
Connect beam's ecosystem is very important for RocketMQ, the plugin rocketmq-spark[1] can be a reference.
[1]. https://github.com/apache/rocketmq-externals/tree/master/rocketmq-spark