ClassRocketMQDataStreamDemoA {@link DataStream} demo that illustrates how to consume messages from RocketMQ, convert messages, then produce messages to RocketMQ. <pre> Argument
ververica-connector-rocketmq-demo/src/main/java/com/alibaba/ververica/connector/demo/RocketMQDataStreamDemo.java:50