tchekai704
/
src-kafka
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

KAFKA-8265: Fix override config name to match KIP-458. (#6776) 

Author: Magesh Nandakumar <magesh.n.kumar@gmail.com>
Reviewer: Randall Hauch <rhauch@gmail.com>
pull/6784/head
Magesh Nandakumar 6 years ago committed by Randall Hauch
parent
d77bac1c93
commit
126230dad0
1 changed files with 3 additions and 3 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 6
      connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java

6
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
Unescape View File

@ -141,9 +141,9 @@ public class ConnectorConfig extends AbstractConfig {
"although some information such as topic and partition number will still be logged."; "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_PRODUCER_OVERRIDES_PREFIX = "producer.override.";
public static final String CONNECTOR_CLIENT_CONSUMER_OVERRIDES_PREFIX = "consumer.overrides."; public static final String CONNECTOR_CLIENT_CONSUMER_OVERRIDES_PREFIX = "consumer.override.";
public static final String CONNECTOR_CLIENT_ADMIN_OVERRIDES_PREFIX = "admin.overrides."; public static final String CONNECTOR_CLIENT_ADMIN_OVERRIDES_PREFIX = "admin.override.";
private final EnrichedConnectorConfig enrichedConfig; private final EnrichedConnectorConfig enrichedConfig;
private static class EnrichedConnectorConfig extends AbstractConfig { private static class EnrichedConnectorConfig extends AbstractConfig {

Write Preview
Loading…
Cancel
Save