Hi Heng Du, Thanks for starting the discussion.
>From the user's perspective, the integration between RocketMQ and Flink is user-friendly. I agree with you the point that polish the existing implementation and add new features, such as table connector support. But before that, you need to provide RocketMQ's Source and Sink (Legacy and FLIP-27 based), TableSource and TableSink. This integration invokes the cooperation between Flink and RocketMQ community, therefore for this community cooperation you could negotiate with Flink community developers like PMC etc. Best, Nicholas Jiang -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
