diff --git a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/CatalogPublishTask.java b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/CatalogPublishTask.java
index e180b41d..32a371b7 100644
--- a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/CatalogPublishTask.java
+++ b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/CatalogPublishTask.java
@@ -91,7 +91,7 @@ public class CatalogPublishTask implements IPublishTask<CmsCatalog> {
         MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
                 "type", Type,
                 "id", dataId
-        )).withId(RecordId.of(Instant.now().toEpochMilli(), catalog.getCatalogId()));
+        ));
         redisTemplate.opsForStream().add(record);
     }
 
diff --git a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/ContentPublishTask.java b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/ContentPublishTask.java
index 53d3ecda..747f333e 100644
--- a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/ContentPublishTask.java
+++ b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/ContentPublishTask.java
@@ -106,7 +106,7 @@ public class ContentPublishTask implements IPublishTask<CmsContent> {
         MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
                 "type", Type,
                 "id", dataId
-        )).withId(RecordId.of(Instant.now().toEpochMilli(), content.getContentId()));
+        ));
         redisTemplate.opsForStream().add(record);
     }
 
diff --git a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/SitePublishTask.java b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/SitePublishTask.java
index 2ccff306..46465f7c 100644
--- a/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/SitePublishTask.java
+++ b/chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/SitePublishTask.java
@@ -33,12 +33,10 @@ import com.chestnut.contentcore.util.TemplateUtils;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.collections4.MapUtils;
 import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.RecordId;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.io.File;
-import java.time.Instant;
 import java.util.Map;
 import java.util.Objects;
 
@@ -75,7 +73,7 @@ public class SitePublishTask implements IPublishTask<CmsSite> {
         MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
                 "type", Type,
                 "id", dataId
-        )).withId(RecordId.of(Instant.now().toEpochMilli(), site.getSiteId()));
+        ));
         redisTemplate.opsForStream().add(record);
     }