特邀发言官fix

2025-06-19 19:49:21 +08:00
parent 03b2cabc89
commit 9550cf76e0
1 changed files with 2 additions and 2 deletions
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/InvitedSpeakerConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/InvitedSpeakerConsumer.java
@@ -10,8 +10,8 @@ import org.springframework.stereotype.Component;

@Slf4j
@Component
-@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.InvitedSpeaker.group}",
-        topic = "${rocketmq.consumer.InvitedSpeaker.topic}",
+@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.invitedSpeaker.group}",
+        topic = "${rocketmq.consumer.invitedSpeaker.topic}",
        enableMsgTrace = true)
 public class InvitedSpeakerConsumer implements RocketMQListener<MessageExt> {