From ef39ecd0df2532bf5772e2d67df195b83b576df9 Mon Sep 17 00:00:00 2001
From: Ashwin Giridharan <girida@amazon.com>
Date: Mon, 22 Jun 2020 23:37:38 -0700
Subject: [PATCH] Log changes

---
 .../kinesis/retrieval/polling/PrefetchRecordsPublisher.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
index d92c60af..ef752f1b 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
@@ -231,8 +231,8 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
             throw new IllegalStateException("ExecutorService has been shutdown.");
         }
         if (!started) {
+            log.info("{} : Starting Prefetching thread and initializing publisher session.", streamAndShardId);
             publisherSession.init(extendedSequenceNumber, initialPositionInStreamExtended);
-            log.info("{} : Starting prefetching thread and initializing publisher session.", streamAndShardId);
             executorService.execute(defaultGetRecordsCacheDaemon);
         } else {
             log.info("{} : Skipping publisher start as it was already started.", streamAndShardId);