apache / apache/rocketmq-flink
Sql Source is no longer compatible.
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
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.
Contributor guide
No contributing guide indexed for this repository
Research direction
Compare the option keys in org.apache.rocketmq.flink.common.RocketMQOptions with those in org.apache.flink.connector.rocketmq.source.RocketMQSourceOptions, focusing on the added rocketmq.source prefix. Reproduce the failure with an existing SQL source DDL and verify that the same DDL remains compatible after the connector version change.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 45/100