diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java index c051327e..0f6025f7 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java @@ -1205,8 +1205,8 @@ public class Worker implements Runnable { private void resetInfoLogging() { if (infoReporting) { - // We just logged at INFO level for a pass through worker loop - if (LOG.isInfoEnabled()) { + // We just logged at minimum INFO level for a pass through worker loop + if (!LOG.isDebugEnabled() || !LOG.isTraceEnabled()) { infoReporting = false; nextReportTime = System.currentTimeMillis() + reportIntervalMillis; } // else is DEBUG or TRACE so leave reporting true