MINOR: reduce verbosity of cache flushes

This log message tends to be extremely verbose when state stores are being restored Author: Xavier Léauté <[email protected]> Reviewers: Guozhang Wang <[email protected]> Closes apache#2412 from xvrl/reduce-verbosity
LioRoger · Jan 20, 2017 · 50e035d · 50e035d
1 parent a37bf5f
commit 50e035d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
@@ -106,8 +106,10 @@ synchronized void flush() {
     private void flush(final LRUNode evicted) {
         numFlushes++;
 
-        log.debug("Named cache {} stats on flush: #hits={}, #misses={}, #overwrites={}, #flushes={}",
-                  name, hits(), misses(), overwrites(), flushes());
+        if (log.isTraceEnabled()) {
+            log.trace("Named cache {} stats on flush: #hits={}, #misses={}, #overwrites={}, #flushes={}",
+                      name, hits(), misses(), overwrites(), flushes());
+        }
 
         if (listener == null) {
             throw new IllegalArgumentException("No listener for namespace " + name + " registered with cache");