kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: HOTFIX: reduce log verbosity on commit
Date Thu, 22 Jun 2017 22:00:42 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 6d2fbfc91 -> 4baca9172


HOTFIX: reduce log verbosity on commit

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 #3414 from mjsax/hotfix-commit-logging


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4baca917
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/4baca917
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/4baca917

Branch: refs/heads/trunk
Commit: 4baca9172dd662c2e45cd99c638a052eeca688c5
Parents: 6d2fbfc
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Thu Jun 22 23:00:29 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu Jun 22 23:00:29 2017 +0100

----------------------------------------------------------------------
 .../apache/kafka/streams/processor/internals/StreamThread.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/4baca917/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
----------------------------------------------------------------------
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
index 887e4b5..46697c1 100644
--- 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 @@ public class StreamThread extends Thread {
 
         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 class StreamThread extends Thread {
      * 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) {


Mime
View raw message