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.