shirukai/rocketmq-flink

Fork https://github.com/apache/rocketmq-flink ,add dynamic property table sink.

JavaApache-2.0