Repository: kafka Updated Branches: refs/heads/trunk 37ec15e96 -> bb9859720
MINOR: change task initialization logging levels In `AssignedTasks` log at debug all task ids that are yet to be initialized. In `StreamsTask` log at trace when the task is initialized. Author: Damian Guy <damian....@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #3905 from dguy/minor-task-init-logging Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bb985972 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bb985972 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bb985972 Branch: refs/heads/trunk Commit: bb9859720bf88732cb63ec27cfa10d510d767d2b Parents: 37ec15e Author: Damian Guy <damian....@gmail.com> Authored: Wed Sep 20 12:07:04 2017 +0100 Committer: Damian Guy <damian....@gmail.com> Committed: Wed Sep 20 12:07:04 2017 +0100 ---------------------------------------------------------------------- .../apache/kafka/streams/processor/internals/AssignedTasks.java | 2 +- .../org/apache/kafka/streams/processor/internals/StreamTask.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/bb985972/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java index 3208f93..e51ebd7 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java @@ -109,7 +109,7 @@ class AssignedTasks { void initializeNewTasks() { if (!created.isEmpty()) { - log.trace("Initializing {}s {}", taskTypeName, created.keySet()); + log.debug("Initializing {}s {}", taskTypeName, created.keySet()); } for (final Iterator<Map.Entry<TaskId, Task>> it = created.entrySet().iterator(); it.hasNext(); ) { final Map.Entry<TaskId, Task> entry = it.next(); http://git-wip-us.apache.org/repos/asf/kafka/blob/bb985972/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java index 0830aa2..6775edb 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java @@ -152,7 +152,7 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator } public boolean initialize() { - log.debug("Initializing"); + log.trace("Initializing"); initializeStateStores(); initTopology(); processorContext.initialized(); @@ -606,5 +606,4 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator RecordCollector createRecordCollector(final LogContext logContext) { return new RecordCollectorImpl(producer, id.toString(), logContext); } - }