You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/09/20 11:07:08 UTC
kafka git commit: MINOR: change task initialization logging levels
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 <da...@gmail.com>
Reviewers: Guozhang Wang <wa...@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 <da...@gmail.com>
Authored: Wed Sep 20 12:07:04 2017 +0100
Committer: Damian Guy <da...@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);
}
-
}