update:调整数据同步生产topic生成器

This commit is contained in:
hewencai
2025-12-17 11:31:57 +08:00
parent 7e25d6d106
commit 738c82b000

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