Sql Source is no longer compatible.

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.

https://rocketmq.apache.org/

Apache License 2.0

139 stars 88 forks source link

Sql Source is no longer compatible. #115

Open loserwang1024 opened 3 months ago

loserwang1024 commented 3 months ago

In current modification, option is changed from org.apache.rocketmq.flink.common.RocketMQOptions to org.apache.flink.connector.rocketmq.source.RocketMQSourceOptions. However, each key's name has been add a prefix of rocketmq.source.

It means that same sql ddl will throw exception if upgrade version of connector.

loserwang1024 commented 3 months ago

@lizhimins , @GOODBOY008 , CC