From 738c82b000660d775de40bb9af65f6e85b40060d Mon Sep 17 00:00:00 2001
From: hewencai <2357300448@qq.com>
Date: Wed, 17 Dec 2025 11:31:57 +0800
Subject: [PATCH] =?UTF-8?q?update=EF=BC=9A=E8=B0=83=E6=95=B4=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=90=8C=E6=AD=A5=E7=94=9F=E4=BA=A7topic=E7=94=9F?=
 =?UTF-8?q?=E6=88=90=E5=99=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../zt/plat/module/databus/enums/DatabusEventType.java   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/zt-module-databus/zt-module-databus-api/src/main/java/com/zt/plat/module/databus/enums/DatabusEventType.java b/zt-module-databus/zt-module-databus-api/src/main/java/com/zt/plat/module/databus/enums/DatabusEventType.java
index 80886ad3..679bfa49 100644
--- a/zt-module-databus/zt-module-databus-api/src/main/java/com/zt/plat/module/databus/enums/DatabusEventType.java
+++ b/zt-module-databus/zt-module-databus-api/src/main/java/com/zt/plat/module/databus/enums/DatabusEventType.java
@@ -311,11 +311,14 @@ public enum DatabusEventType {
     }
 
     /**
-     * 获取完整Topic名称（服务端转发用）
-     * 格式: {topicBase}-{module}-{entity}-{action}-{clientCode}
+     * 获取完整Topic名称（服务端转发用 - 统一消费者架构）
+     * <p>
+     * 新架构：所有事件类型都推送到同一个客户端 Topic，通过消息体中的 eventType 字段区分
+     * 格式: {topicBase}-{clientCode}
+     * 示例: databus-sync-hwc-test
      */
     public String getTopic(String topicBase, String clientCode) {
-        return String.format("%s-%s-%s-%s-%s", topicBase, module, entity, action, clientCode);
+        return String.format("%s-%s", topicBase, clientCode);
     }
 
     /**