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名称(服务端转发用 - 统一消费者架构) + *

+ * 新架构:所有事件类型都推送到同一个客户端 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); } /**