diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
index afcc328..ef09f4b 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
@@ -86,11 +86,12 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDa
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(AppAutoDataMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+//        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
index ee6defd..0a63fd7 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldHeartConsumer.java
@@ -68,11 +68,12 @@ public class CldHeartConsumer extends EnhanceConsumerMessageHandler<CldHeartBeat
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(CldHeartBeatMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+//        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
index 341753b..c49979a 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/RealDataConsumer.java
@@ -71,11 +71,11 @@ public class RealDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDataM
     }
 
     /**
-     * 消费成功，缓存到redis72小时，避免重复消费
+     * 消费成功，缓存到redis 5分钟，避免重复消费
      */
     @Override
     protected void consumeSuccess(AppAutoDataMessage message) {
-        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, 5 * 60L);
     }
 
     /**