From 126230dad0ca9e4660ad2f1912935c41bce77ea9 Mon Sep 17 00:00:00 2001 From: Magesh Nandakumar Date: Tue, 21 May 2019 09:28:29 -0700 Subject: [PATCH] KAFKA-8265: Fix override config name to match KIP-458. (#6776) Author: Magesh Nandakumar Reviewer: Randall Hauch --- .../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 1cebc94222f..632f5d3454e 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 {