bug修复

bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java

@@ -106,11 +106,9 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
      */
     @Transactional
     public <T> OrderMqMessageRecord saveMessageRecord(String topic, String tag, T message){
-        RocketMQTemplate rocketMQTemplate = rocketMQEnhanceTemplate.getTemplate();
-        String consumerGroup = rocketMQTemplate.getConsumer().getConsumerGroup();
         OrderMqMessageRecord orderMqMessageRecord = new OrderMqMessageRecord();
         orderMqMessageRecord.setStatus(EnumMessageStatus.PROCESS);
-        orderMqMessageRecord.setConsumerGroupName(consumerGroup);
+        orderMqMessageRecord.setConsumerGroupName(topic);
         orderMqMessageRecord.setTopic(topic);
         orderMqMessageRecord.setTag(tag);
         orderMqMessageRecord.setCreateTime(new Date());