RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
Tips
Thank you very much for contributing to Apache rocketmq-flink.
What is the purpose of the pull request
*solve RocketMQRecordEmitterTest has format violations
Brief change log
(for example:)
*Modify RocketMQRecordEmitterTest.java
Verify this pull request
RocketMQRecordEmitterTest.java
upgrade flink version to 1.14.0
Tips Thank you very much for contributing to Apache rocketmq-flink. What is the purpose of the pull request *solve RocketMQRecordEmitterTest has format violations
Brief change log (for example:)
*Modify RocketMQRecordEmitterTest.java Verify this pull request RocketMQRecordEmitterTest.java