https://github.com/apache/rocketmq-externals/tree/master/rocketmq-flink
https://issues.apache.org/jira/browse/ROCKETMQ-82