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 52ec1468..e8406d92 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 @@ -200,11 +200,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 " - + "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" - + "intermittent ReadTimeout warnings. Last successful request details -- {}", + + " 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" + + " intermittent ReadTimeout warnings. Last successful request details -- {}", shardInfoId, recordsPublisher.getLastSuccessfulRequestDetails(), t); }