diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java index 685a76d2..712856a4 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java @@ -199,11 +199,11 @@ class ShardConsumerSubscriber implements Subscriber { } protected void logOnErrorReadTimeoutWarning(Throwable t) { - log.warn("{}: onError(). Cancelling subscription, and marking self as failed. KCL will" - + " recreate the subscription as neccessary to continue processing. If you " + log.warn("{}: onError(). Cancelling subscription, and marking self as failed. KCL will " + + "recreate the subscription as necessary to continue processing. If you " + "are seeing this warning frequently consider increasing the SDK timeouts " - + "by providing an OverrideConfiguration to the kinesis client. Alternatively you" - + "can configure LifecycleConfig.readTimeoutsToIgnoreBeforeWarning to suppress" + + "by providing an OverrideConfiguration to the kinesis client. Alternatively you " + + "can configure LifecycleConfig.readTimeoutsToIgnoreBeforeWarning to suppress " + "intermittent ReadTimeout warnings. Last successful request details -- {}", shardInfoId, recordsPublisher.getLastSuccessfulRequestDetails(), t); }