/rocketMQ-flink-connector

Production uses stable version fork from offical.Support the new source interface and the old source interface.

Primary LanguageJavaApache License 2.0Apache-2.0

Stargazers