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.
Some metrics are not exist in this project，and some metrics are incompatible with existing specification，and I want to modify the code so that these metrics more compliant.
This is my PR：https://github.com/apache/rocketmq-flink/pull/84
Some metrics are not exist in this project，and some metrics are incompatible with existing specification，and I want to modify the code so that these metrics more compliant. This is my PR：https://github.com/apache/rocketmq-flink/pull/84