search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

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

Open humkum opened 10 months ago

humkum commented 10 months ago

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

lizhimins commented 9 months ago

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

humkum commented 9 months ago

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

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

humkum commented 3 months ago

This issue could be closed.