diff --git a/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java b/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
index fe2e4d5..f4b2fda 100644
--- a/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
+++ b/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
@@ -2414,7 +2414,13 @@ public class AgentServiceImpl implements AgentService {
 
                     // 获取当前文件的时间戳用于日志
                     String currentTimestamp = file.getName().replace(".conf", "");
-
+                    // 特殊处理：如果是最后一个文件，等待1分钟再发送
+                    if (isLastTraffic) {
+                        long lastMessageDelay = 60000; // 1分钟
+                        AssertLog.info("最后一个文件 {} 已发送，等待 {}ms 确保前面消息都被消费",
+                                currentTimestamp, lastMessageDelay);
+                        Thread.sleep(lastMessageDelay);
+                    }
                     processSingleFile(file, isLastTraffic);
                     batchProcessed++;
                     totalProcessed++;