rocketmq-spring icon indicating copy to clipboard operation
rocketmq-spring copied to clipboard

How to dynamically configure consumerGroup in @RocketMQMessageListener

Open HildaM opened this issue 3 years ago • 0 comments

FEATURE REQUEST

  1. Please describe the feature you are requesting. How to dynamically configure consumerGroup in @RocketMQMessageListener?

  2. 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: image 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 . image

  1. 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.

HildaM avatar Oct 08 '22 08:10 HildaM