From 6a7211ed0319973f6ccc510532a19b5aa72265c2 Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 21 Feb 2025 16:14:46 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3581:=20=E5=A4=87=E4=BB=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/axzo/nanopart/ess/server/ess/PersonResignListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/PersonResignListener.java b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/PersonResignListener.java index 7d8ddff6..f4abcbdc 100644 --- a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/PersonResignListener.java +++ b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/PersonResignListener.java @@ -32,7 +32,7 @@ import java.util.Collections; maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - topic = "topic_organizational__${spring.profiles.active}", + topic = "topic_organizational_${spring.profiles.active}", consumerGroup = "GID_ess_person_resign_${spring.application.name}_${spring.profiles.active}" ) public class PersonResignListener extends BaseListener