apache / apache/rocketmq-flink
RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes.
Open
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes, if topic route info changes, it would throw RuntimeException without resolving that:

Contributor guide
No contributing guide indexed for this repository
Research direction
Start at RocketMQSourceFunction and reproduce the failure when topic route information changes. Trace the routing and exception path shown in the issue; done means the source dynamically detects route changes without throwing an unresolved RuntimeException.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 28/100