You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2016/11/09 22:58:57 UTC
kafka git commit: KAFKA-4364: Remove secrets from DEBUG logging
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 <ry...@gmail.com>
Reviewers: Ewen Cheslack-Postava <ew...@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 <ry...@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.");