From 6cb01001638ff04a6eb9ad8168e4590d825a7599 Mon Sep 17 00:00:00 2001 From: JumpeiAnzai <53547731+JumpeiAnzai@users.noreply.github.com> Date: Wed, 1 Feb 2023 08:36:12 +0900 Subject: [PATCH] Fixing log message spacing (#795) --- .../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(); }