From 8675a1cf920f264f49640c6c4f3c21d80bb9e7ed Mon Sep 17 00:00:00 2001
From: anzai <anzai@geologic.co.jp>
Date: Fri, 19 Mar 2021 14:30:25 +0900
Subject: [PATCH] Fixing log message spacing

---
 .../amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java
index 7e8932cf..8404925d 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java
@@ -381,7 +381,7 @@ public class FanOutRecordsPublisher implements RecordsPublisher {
     private void resetRecordsDeliveryStateOnSubscriptionOnInit() {
         // Clear any lingering records in the queue.
         if (!recordsDeliveryQueue.isEmpty()) {
-            log.warn("{}: Found non-empty queue while starting subscription. This indicates unsuccessful clean up of"
+            log.warn("{}: Found non-empty queue while starting subscription. This indicates unsuccessful clean up of "
                     + "previous subscription - {}. Last successful request details -- {}", streamAndShardId, subscribeToShardId, lastSuccessfulRequestDetails);
             recordsDeliveryQueue.clear();
         }