diff --git a/ms-biz/src/main/java/com/ms/biz/quque/Topic.java b/ms-biz/src/main/java/com/ms/biz/quque/Topic.java
index 0417cdb..b5df6e4 100644
--- a/ms-biz/src/main/java/com/ms/biz/quque/Topic.java
+++ b/ms-biz/src/main/java/com/ms/biz/quque/Topic.java
@@ -3,7 +3,7 @@ package com.ms.biz.quque;
 import com.ms.biz.tool.SystemTool;
 
 public class Topic {
-    public static final String TOPIC_DS_MESSAGE = "miaoshougoods_rsync_order";
+    public static final String TOPIC_DS_MESSAGE = "miaoshougoods_ds_message";
     public static String rebuild(String topic) {
         if (SystemTool.isDevEnv()) {
             return "local%" + topic;