From 7a01d379b6f76c54c964ee7fd6ff9155c9bde261 Mon Sep 17 00:00:00 2001
From: "Pfifer, Justin" <pfifer@amazon.com>
Date: Mon, 20 Aug 2018 07:15:25 -0700
Subject: [PATCH] Update the lastRequestTime to prevent overlapping restarts.

When a restart occurs due to no activity set the lastRequestTime to
now to prevent ti from overlapping itself.
---
 .../software/amazon/kinesis/lifecycle/ShardConsumer.java     | 5 +++++
 1 file changed, 5 insertions(+)

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 6789cc6ca..60197b63a 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
@@ -265,6 +265,11 @@ Throwable healthCheck() {
                     if (subscriber != null) {
                         subscriber.cancel();
                     }
+                    //
+                    // Set the last request time to now, we specifically don't null it out since we want it to trigger a
+                    // restart if the subscription still doesn't start producing.
+                    //
+                    lastRequestTime = Instant.now();
                     startSubscriptions();
                 }
             }