diff --git a/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java b/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
index 23daaa9d..7ca38b8d 100644
--- a/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
+++ b/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.bean.copier.CopyOptions;
 import cn.hutool.core.convert.ConvertException;
 import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
@@ -102,6 +103,9 @@ public class ConsumerWorker implements Runnable {
         }catch (Exception e){
             logger.error("error_msg={}",e.getMessage());
         }
+        if(DateUtil.between(esGpsInfo.getGpsTime(), new Date(), DateUnit.SECOND) > 2000L){
+            return;
+        }
         logger.info("esGpsInfo={}",esGpsInfo);
         boolean offer = linkedBlockingDeque.offer(esGpsInfo);
         R response = R.ok(offer);