Merge branch 'dev' into 'test'

Dev

See merge request jygk/dsc!11
This commit is contained in:
wencai he
2025-12-17 03:32:22 +00:00

View File

@@ -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);
}
/**