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

This commit is contained in:
hewencai
2025-12-17 11:31:57 +08:00
parent 13403ea027
commit 2baede83e5

View File

@@ -311,11 +311,14 @@ public enum DatabusEventType {
} }
/** /**
* 获取完整Topic名称服务端转发用 * 获取完整Topic名称服务端转发用 - 统一消费者架构
* 格式: {topicBase}-{module}-{entity}-{action}-{clientCode} * <p>
* 新架构:所有事件类型都推送到同一个客户端 Topic通过消息体中的 eventType 字段区分
* 格式: {topicBase}-{clientCode}
* 示例: databus-sync-hwc-test
*/ */
public String getTopic(String topicBase, String clientCode) { 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);
} }
/** /**