HOTFIX: reduce log verbosity on commit

mjsax · ijuma · commit f4ac58a062c4 · 2017-06-22T23:00:47.000+01:00
Author: Matthias J. Sax <matthias@confluent.io> Reviewers: Bill Bejeck <bbejeck@gmail.com>, Eno Thereska <eno.thereska@gmail.com>, Ismael Juma <ismael@juma.me.uk> Closes apache#3414 from mjsax/hotfix-commit-logging (cherry picked from commit 4baca91) Signed-off-by: Ismael Juma <ismael@juma.me.uk>
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -772,7 +772,7 @@ protected void maybeCommit(final long now) {
 
         if (commitTimeMs >= 0 && lastCommitMs + commitTimeMs < now) {
 
-            log.info("{} Committing all active tasks {} and standby tasks {} because the commit interval {}ms has elapsed by {}ms",
+            log.debug("{} Committing all active tasks {} and standby tasks {} because the commit interval {}ms has elapsed by {}ms",
                 logPrefix, activeTasks.keySet(), standbyTasks.keySet(), commitTimeMs, now - lastCommitMs);
 
             commitAll();
@@ -810,7 +810,7 @@ public void apply(final StreamTask task) {
      * Commit the state of a task
      */
     private void commitOne(final AbstractTask task) {
-        log.info("{} Committing task {} {}", logPrefix, task.getClass().getSimpleName(), task.id());
+        log.trace("{} Committing {} {}", logPrefix, task.getClass().getSimpleName(), task.id());
         try {
             task.commit();
         } catch (final CommitFailedException e) {
