rocketmq-spring
rocketmq-spring copied to clipboard
How to dynamically configure consumerGroup in @RocketMQMessageListener
FEATURE REQUEST
-
Please describe the feature you are requesting. How to dynamically configure consumerGroup in @RocketMQMessageListener?
-
Provide any additional detail on your proposed use case for this feature. While I'm using @KafkaListener on my consumer method, I could use aop to dynamically configure consumerGroup. Here is example:
The configuration of consumerGroup is based on my project setting, this can reduce unnessary code.
But while using @RocketMQMessageListener, I notice that the consumerGroup value require it to be fixed. And I look up the document of Rocket-spring and couldn't find any AOP method to dynamically configure consumerGroup .

- Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue? It can reduce lots of unnessary code, Improve efficiency.