Fork https://github.com/apache/rocketmq-flink ,add dynamic property table sink.
Primary LanguageJavaApache License 2.0Apache-2.0