apache / apache/rocketmq-flink

RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes.

Open
#97 3 comments 0 reactions 0 assignees View on GitHub
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:
![image](https://github.com/apache/rocketmq-flink/assets/50660789/98e23aff-1e9c-4b53-8ef3-b7ab1e4c1a55)

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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.