Check MillisBehindLatest in deciding to skip tick

harlow · Aug 1, 2020 · cdbd293 · cdbd293
1 parent 0a399d6
commit cdbd293
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer.go b/consumer.go
@@ -208,8 +208,8 @@ func (c *Consumer) ScanShard(ctx context.Context, shardID string, fn ScanFunc) e
 			}
 
 			shardIterator = resp.NextShardIterator
-			if c.immediateRescan && len(resp.Records) > 0 {
-				// We have records with immediate rescan enabled, so skip waiting for next tick
+			if c.immediateRescan && len(resp.Records) > 0 && *resp.MillisBehindLatest > 0 {
+				// There appears to be additional records, so skip waiting for next tick
 				continue
 			}
 		}