Repository: kafka Updated Branches: refs/heads/trunk 2ce328529 -> e18bbba77
KAFKA-2935: Remove vestigial WorkerConfig.CLUSTER_CONFIG Author: shikhar <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #1404 from shikhar/kafka-2935 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e18bbba7 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e18bbba7 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e18bbba7 Branch: refs/heads/trunk Commit: e18bbba77fcab9667536f624f85576516aff55be Parents: 2ce3285 Author: shikhar <[email protected]> Authored: Thu May 19 09:25:06 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Thu May 19 09:25:06 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/kafka/connect/runtime/WorkerConfig.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/e18bbba7/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java ---------------------------------------------------------------------- diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java index 7ede130..354da9b 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java @@ -31,12 +31,6 @@ import java.util.Map; @InterfaceStability.Unstable public class WorkerConfig extends AbstractConfig { - public static final String CLUSTER_CONFIG = "cluster"; - private static final String CLUSTER_CONFIG_DOC = - "ID for this cluster, which is used to provide a namespace so multiple Kafka Connect clusters " - + "or instances may co-exist while sharing a single Kafka cluster."; - public static final String CLUSTER_DEFAULT = "connect"; - public static final String BOOTSTRAP_SERVERS_CONFIG = "bootstrap.servers"; public static final String BOOTSTRAP_SERVERS_DOC = "A list of host/port pairs to use for establishing the initial connection to the Kafka " @@ -122,7 +116,6 @@ public class WorkerConfig extends AbstractConfig { */ protected static ConfigDef baseConfigDef() { return new ConfigDef() - .define(CLUSTER_CONFIG, Type.STRING, CLUSTER_DEFAULT, Importance.HIGH, CLUSTER_CONFIG_DOC) .define(BOOTSTRAP_SERVERS_CONFIG, Type.LIST, BOOTSTRAP_SERVERS_DEFAULT, Importance.HIGH, BOOTSTRAP_SERVERS_DOC) .define(KEY_CONVERTER_CLASS_CONFIG, Type.CLASS,
