diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java
index 60197b63..134f30d4 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java
@@ -299,7 +299,9 @@ public class ShardConsumer {
             if (lastDataArrival != null) {
                 Instant now = Instant.now();
                 Duration timeSince = Duration.between(subscriber.lastDataArrival, now);
-                log.warn("Last time data arrived: {} ({})", lastDataArrival, timeSince);
+                if (timeSince.toMillis() > value) {
+                    log.warn("Last time data arrived: {} ({})", lastDataArrival, timeSince);
+                }
             }
         });
     }