From c1e38f0126d8b4ecab9ca927650b3d7f0c604836 Mon Sep 17 00:00:00 2001
From: Justin Pfifer <pfifer@amazon.com>
Date: Mon, 20 Aug 2018 09:25:57 -0700
Subject: [PATCH] Update the lastRequestTime to prevent overlapping restarts.
 (#373)

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 6789cc6c..60197b63 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 @@ public class ShardConsumer {
                     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();
                 }
             }