feat: add dynamicTag for RocketMQ #5471
Open
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
提交了dynamicTag的支持,使用dynamicTopic相同的匹配分隔逻辑。遗憾的是,对于目前支持的所有MQ,感觉仅RocketMQ对tag的支持是更有意义的,因此该提交仅处理了CanalRocketMQProducer的支持。这样的实现看起来有些异味,只是目前存在这样的需求,对RocketMQ同个topic下的消息标记tag,消费端按需过滤不同的tag。另外在issues中也看到一些同样的对dynamicTag的需求,如:5375,4468,3409,1793 等。
请评估下是否可以支持该功能,谢谢。