You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2020/02/26 22:57:59 UTC
[kafka] branch 2.1 updated: KAFKA-9601: Stop logging raw connector
config values (#8165)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push:
new a7e203e KAFKA-9601: Stop logging raw connector config values (#8165)
a7e203e is described below
commit a7e203e18f001ece4aeb6b54c0b78b3fcc89952c
Author: Chris Egerton <ch...@confluent.io>
AuthorDate: Wed Feb 26 13:52:16 2020 -0800
KAFKA-9601: Stop logging raw connector config values (#8165)
Author: Chris Egerton <ch...@confluent.io>
Reviewer: Randall Hauch <rh...@gmail.com>
---
.../src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
index 55d4860..b1c0b66 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
@@ -76,7 +76,7 @@ public class WorkerConnector {
public void initialize(ConnectorConfig connectorConfig) {
try {
this.config = connectorConfig.originalsStrings();
- log.debug("{} Initializing connector {} with config {}", this, connName, config);
+ log.debug("{} Initializing connector {}", this, connName);
if (isSinkConnector()) {
SinkConnectorConfig.validate(config);
}