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

[humkum]

RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes, if topic route info changes, it would throw RuntimeException without resolving that:

[lizhimins]

可以看下新版本的实现，默认是一致性哈希。legacy 中的实现是通过 runtime exception 触发 fo，这个不是很优雅

[humkum]

可以看下新版本的实现，默认是一致性哈希。legacy 中的实现是通过 runtime exception 触发 fo，这个不是很优雅

是的，flink jar 中会使用 legacy，这个有考虑支持下么？

[humkum]

This issue could be closed.