From 99667e8f505c1437acbe6202c9c5f5e7adc3e1cb Mon Sep 17 00:00:00 2001
From: Justin Pfifer <pfifer@amazon.com>
Date: Thu, 23 Aug 2018 13:16:53 -0700
Subject: [PATCH] Respect logWarningForTaskAfterMillis for logging a retrieval
 warning (#383)

Only log a warning if it's been > logWarningForTaskAfterMillis time
since data was last received.
---
 .../java/software/amazon/kinesis/lifecycle/ShardConsumer.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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);
+                }
             }
         });
     }