root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Matthias J. Sax 2017-06-22 23:00:29 +01:00 committed by Ismael Juma
parent 6d2fbfc911
commit 4baca9172d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
View File

@ -772,7 +772,7 @@ public class StreamThread extends Thread {
if (commitTimeMs >= 0 && lastCommitMs + commitTimeMs < 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); logPrefix, activeTasks.keySet(), standbyTasks.keySet(), commitTimeMs, now - lastCommitMs);
commitAll(); commitAll();
@ -810,7 +810,7 @@ public class StreamThread extends Thread {
* Commit the state of a task * Commit the state of a task
*/ */
private void commitOne(final AbstractTask 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 { try {
task.commit(); task.commit();
} catch (final CommitFailedException e) { } catch (final CommitFailedException e) {