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/21 16:28:44 UTC
[kafka] branch trunk 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 trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 126230d KAFKA-8265: Fix override config name to match KIP-458. (#6776)
126230d is described below
commit 126230dad0ca9e4660ad2f1912935c41bce77ea9
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 {