[remove] test

shard_consumer.go

@@ -193,6 +193,12 @@ mainloop:
 			continue mainloop
 		}
 
+		// sleep for 5 minutes + 5 sec, to make sure the shard iterator expires
+		fmt.Println("Sleeping for 305 seconds")
+		fmt.Printf("pre-sleep time.Now: %s\n", time.Now().Format(time.RFC3339))
+		time.Sleep(305 * time.Second)
+		fmt.Printf("post-sleep time.Now: %s\n", time.Now().Format(time.RFC3339))
+
 		// Get records from kinesis
 		records, next, lag, err := getRecords(k.kinesis, iterator)
 
@@ -208,12 +214,14 @@ mainloop:
 
 				switch awsErr.Code() {
 				case kinesis.ErrCodeExpiredIteratorException:
+					fmt.Printf("Renewing expired shard [id: %s] iterator\n", shardID)
 					newIterator, ierr := getShardIterator(k.kinesis, k.streamName, shardID, lastSeqToCheckp, nil)
 					if ierr != nil {
 						k.shardErrors <- shardConsumerError{shardID: shardID, action: "getShardIterator", err: err}
 						return
 					}
 					iterator = newIterator
+					fmt.Printf("Renewed expired shard [id: %s] iterator successfully\n", shardID)
 					// should retry after expired iterator is renewed successfully
 					shouldRetry = true
 				}