diff --git a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/constants/TopicConstants.java b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/constants/TopicConstants.java
index f4c2d45e89..b4e5d77cd9 100644
--- a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/constants/TopicConstants.java
+++ b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/constants/TopicConstants.java
@@ -8,70 +8,70 @@ public interface TopicConstants {
     /**
      * 初始化客户
      */
-    String INIT_CUSTOMER = "init_customer";
+    String INIT_CUSTOMER = "epmet_init_customer";
     /**
      * 项目变动
      */
-    String PROJECT_CHANGED = "project_changed";
+    String PROJECT_CHANGED = "epmet_project_changed";
 
     /**
      * 小组成就
      */
-    String GROUP_ACHIEVEMENT = "group_achievement";
+    String GROUP_ACHIEVEMENT = "epmet_group_achievement";
 
     /**
      * 认证
      */
-    String AUTH = "auth";
+    String AUTH = "epmet_auth";
 
     /**
      * 积分系统话题
      */
-    String POINT = "point";
+    String POINT = "epmet_point";
 
     /**
      * 组织信息
      */
-    String ORG = "org";
+    String ORG = "epmet_org";
 
     /**
      * 工作人员
      */
-    String STAFF = "staff";
+    String STAFF = "epmet_staff";
 
     /**
      * 巡查记录
      */
-    String PATROL = "patrol";
+    String PATROL = "epmet_patrol";
 
     /**
      * 项目
      */
-    String PROJECT = "project";
+    String PROJECT = "epmet_project";
 
     /**
      * 项目
      */
-    String IC_RESI_USER = "ic_resi_user";
+    String IC_RESI_USER = "epmet_ic_resi_user";
 
     /**
      *  需求完成
      *  1、如果服务方是区域化党建单位，重新计算这个单位的满意度
      */
-    String USER_DEMAND = "user_demand";
+    String USER_DEMAND = "epmet_user_demand";
 
     /**
      * 爱心互助
      */
-    String EPMET_HEART = "epmet_heart";
+    String EPMET_HEART = "epmet_epmet_heart";
 
     /**
      * 楼院小组
      */
-    String RESI_GROUP = "resi_group";
+    String RESI_GROUP = "epmet_resi_group";
 
     /**
      * 社区服务，原居民需求
      */
-    String COMMUNITY_SERVICE="community_service";
+    String COMMUNITY_SERVICE="epmet_community_service";
 }