Commit defb86b1c5fb9013d1f632e433c72a352a9c4684
1 parent
403d17a3
C_G
Showing
1 changed file
with
1 additions
and
1 deletions
src/main/java/org/apache/rocketmq/spring/starter/AliyunRocketMQAutoConfiguration.java
| @@ -186,7 +186,7 @@ public class AliyunRocketMQAutoConfiguration { | @@ -186,7 +186,7 @@ public class AliyunRocketMQAutoConfiguration { | ||
| 186 | String topic = rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.topic()); | 186 | String topic = rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.topic()); |
| 187 | log.info(uuid+"订阅的主题topic:"+topic); | 187 | log.info(uuid+"订阅的主题topic:"+topic); |
| 188 | beanBuilder.addPropertyValue(PROP_TOPIC, topic); | 188 | beanBuilder.addPropertyValue(PROP_TOPIC, topic); |
| 189 | - String cid = "CID_"+rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.consumerGroup()); | 189 | + String cid = "GID_"+rocketMQProperties.getEnvironmentPrefix()+"_"+environment.resolvePlaceholders(annotation.consumerGroup()); |
| 190 | log.info(uuid+"消费者CID:"+cid); | 190 | log.info(uuid+"消费者CID:"+cid); |
| 191 | //消费者ConsumerId添加前缀：PID_+环境标识_+groupName | 191 | //消费者ConsumerId添加前缀：PID_+环境标识_+groupName |
| 192 | beanBuilder.addPropertyValue(PROP_CONSUMER_GROUP, cid); | 192 | beanBuilder.addPropertyValue(PROP_CONSUMER_GROUP, cid); |