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 2019/05/22 00:30:01 UTC
[kafka] branch 2.3 updated: KAFKA-8265: Fix override config name to
match KIP-458. (#6776)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new 93c4745 KAFKA-8265: Fix override config name to match KIP-458. (#6776)
93c4745 is described below
commit 93c474507699943bf320a41fc7400935fb5844ae
Author: Magesh Nandakumar <ma...@gmail.com>
AuthorDate: Tue May 21 09:28:29 2019 -0700
KAFKA-8265: Fix override config name to match KIP-458. (#6776)
Author: Magesh Nandakumar <ma...@gmail.com>
Reviewer: Randall Hauch <rh...@gmail.com>
---
.../main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
index 1cebc94..632f5d3 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
@@ -141,9 +141,9 @@ public class ConnectorConfig extends AbstractConfig {
"although some information such as topic and partition number will still be logged.";
- public static final String CONNECTOR_CLIENT_PRODUCER_OVERRIDES_PREFIX = "producer.overrides.";
- public static final String CONNECTOR_CLIENT_CONSUMER_OVERRIDES_PREFIX = "consumer.overrides.";
- public static final String CONNECTOR_CLIENT_ADMIN_OVERRIDES_PREFIX = "admin.overrides.";
+ public static final String CONNECTOR_CLIENT_PRODUCER_OVERRIDES_PREFIX = "producer.override.";
+ public static final String CONNECTOR_CLIENT_CONSUMER_OVERRIDES_PREFIX = "consumer.override.";
+ public static final String CONNECTOR_CLIENT_ADMIN_OVERRIDES_PREFIX = "admin.override.";
private final EnrichedConnectorConfig enrichedConfig;
private static class EnrichedConnectorConfig extends AbstractConfig {