rocketmq 动态设置topic和consumerGroup

@Override
public void afterPropertiesSet() throws Exception {
    final RocketMQMessageListener annotation = MyConsumer.class.getAnnotation(RocketMQMessageListener.class);
    InvocationHandler h = Proxy.getInvocationHandler(annotation);
    Field hField = h.getClass().getDeclaredField("memberValues");
    hField.setAccessible(true);
    Map memberValues = (Map) hField.get(h);
    memberValues.put("topic", topic);
    memberValues.put("consumerGroup", consumerGroup);
}
此时 topic  consumerGroup 就可以通过配置中心或者文件来动态配置
比如：
@Value("${dynamic.spring.rocketmq.topic}"
private String topic