luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix warning message typos (#956)

Browse source 
Same as #875
This commit is contained in:
Ben Iofel 2023-01-31 18:26:14 -05:00 committed by GitHub
parent 28cb185e9c
commit 0535193394
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java
View file

@ -200,11 +200,11 @@ class ShardConsumerSubscriber implements Subscriber<RecordsRetrieved> {
protected void logOnErrorReadTimeoutWarning(Throwable t) { protected void logOnErrorReadTimeoutWarning(Throwable t) {
log.warn("{}: onError(). Cancelling subscription, and marking self as failed. KCL will" log.warn("{}: onError(). Cancelling subscription, and marking self as failed. KCL will"
+ " recreate the subscription as neccessary to continue processing. If you " + " recreate the subscription as necessary to continue processing. If you"
+ "are seeing this warning frequently consider increasing the SDK timeouts " + " are seeing this warning frequently consider increasing the SDK timeouts"
+ "by providing an OverrideConfiguration to the kinesis client. Alternatively you" + " by providing an OverrideConfiguration to the kinesis client. Alternatively you"
+ "can configure LifecycleConfig.readTimeoutsToIgnoreBeforeWarning to suppress" + " can configure LifecycleConfig.readTimeoutsToIgnoreBeforeWarning to suppress"
+ "intermittent ReadTimeout warnings. Last successful request details -- {}", + " intermittent ReadTimeout warnings. Last successful request details -- {}",
shardInfoId, recordsPublisher.getLastSuccessfulRequestDetails(), t); shardInfoId, recordsPublisher.getLastSuccessfulRequestDetails(), t);
} }