kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-4364: Remove secrets from DEBUG logging
Date Wed, 09 Nov 2016 22:58:57 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk a66ca1624 -> da13b5378


KAFKA-4364: Remove secrets from DEBUG logging

leverage fix from KAFKA-2690 to remove secrets from task logging

Author: rnpridgeon <ryan.n.pridgeon@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #2115 from rnpridgeon/KAFKA-4364


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

Branch: refs/heads/trunk
Commit: da13b537871ee59d30fb82703de4b6b1fcb11dff
Parents: a66ca16
Author: rnpridgeon <ryan.n.pridgeon@gmail.com>
Authored: Wed Nov 9 14:57:31 2016 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Wed Nov 9 14:58:02 2016 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java | 2 +-
 .../main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/da13b537/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
index 48cb4d8..9552fe9 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
@@ -49,6 +49,6 @@ public class TaskConfig extends AbstractConfig {
     }
 
     public TaskConfig(Map<String, ?> props) {
-        super(config, props);
+        super(config, props, true);
     }
 }

http://git-wip-us.apache.org/repos/asf/kafka/blob/da13b537/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
index 4181799..a48489e 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
@@ -210,7 +210,7 @@ class WorkerSinkTask extends WorkerTask {
      * Initializes and starts the SinkTask.
      */
     protected void initializeAndStart() {
-        log.debug("Initializing task {} with config {}", id, taskConfig);
+        log.debug("Initializing task {} ", id);
         String topicsStr = taskConfig.get(SinkTask.TOPICS_CONFIG);
         if (topicsStr == null || topicsStr.isEmpty())
             throw new ConnectException("Sink tasks require a list of topics.");


Mime
View raw message