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

Respect logWarningForTaskAfterMillis for logging a retrieval warning (#383)

Browse source 
Only log a warning if it's been > logWarningForTaskAfterMillis time
since data was last received.
This commit is contained in:
Justin Pfifer 2018-08-23 13:16:53 -07:00 committed by Sahil Palvia
parent e3eff0dc3c
commit 99667e8f50
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java
View file

@ -299,7 +299,9 @@ public class ShardConsumer {
if (lastDataArrival != null) { if (lastDataArrival != null) {
Instant now = Instant.now(); Instant now = Instant.now();
Duration timeSince = Duration.between(subscriber.lastDataArrival, now); Duration timeSince = Duration.between(subscriber.lastDataArrival, now);
log.warn("Last time data arrived: {} ({})", lastDataArrival, timeSince); if (timeSince.toMillis() > value) {
log.warn("Last time data arrived: {} ({})", lastDataArrival, timeSince);
}
} }
}); });
} }