kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-2935: Remove vestigial WorkerConfig.CLUSTER_CONFIG
Date Thu, 19 May 2016 16:25:19 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2ce328529 -> e18bbba77


KAFKA-2935: Remove vestigial WorkerConfig.CLUSTER_CONFIG

Author: shikhar <shikhar@schmizz.net>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

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 <shikhar@schmizz.net>
Authored: Thu May 19 09:25:06 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
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,


Mime
View raw message