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 <[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 {
