From defb86b1c5fb9013d1f632e433c72a352a9c4684 Mon Sep 17 00:00:00 2001 From: wangbiao Date: Thu, 25 Apr 2019 18:24:04 +0800 Subject: [PATCH] C_G --- src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java b/src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java index 5113c80..f21de49 100644 --- a/src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java +++ b/src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java @@ -186,7 +186,7 @@ public class AliyunRocketMQAutoConfiguration { String topic = rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.topic()); log.info(uuid+"订阅的主题topic:"+topic); beanBuilder.addPropertyValue(PROP_TOPIC, topic); - String cid = "CID_"+rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.consumerGroup()); + String cid = "GID_"+rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.consumerGroup()); log.info(uuid+"消费者CID:"+cid); //消费者ConsumerId添加前缀：PID_+环境标识_+groupName beanBuilder.addPropertyValue(PROP_CONSUMER_GROUP, cid); -- libgit2 0.21.4