RocketMQ声明topic以及consumergroup根据不同环境隔离

其实很简单, 直接上代码

@RocketMQMessageListener(topic = "${spring.profiles.active}_yourtopic", consumerGroup = "${spring.profiles.active}_yourgroup")
public class YourConsumer{
		....
}

这样就可以自动找到你在项目中激活的配置文件,这样你声明的topic以及consumergroup就会自动加上对应环境前缀做隔离