HOTFIX: reduce log verbosity on commit

Author: Matthias J. Sax <[email protected]> Reviewers: Bill Bejeck <[email protected]>, Eno Thereska <[email protected]>, Ismael Juma <[email protected]> Closes apache#3414 from mjsax/hotfix-commit-logging
alexissellier · Jun 22, 2017 · 4baca91 · 4baca91
1 parent 6d2fbfc
commit 4baca91
Showing 1 changed file with 2 additions and 2 deletions.
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) {