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 <[email protected]>
AuthorDate: Tue May 21 09:28:29 2019 -0700
KAFKA-8265: Fix override config name to match KIP-458. (#6776)
Author: Magesh Nandakumar <[email protected]>
Reviewer: Randall Hauch <[email protected]>
---
.../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 {
