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-4679: Remove unstable markers from Connect APIs
Date Sat, 28 Jan 2017 03:58:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 6cb76b95a -> 1434b61d5


KAFKA-4679: Remove unstable markers from Connect APIs

ewencp ignore this PR if you are already started to work on this ticket.

Author: Balint Molnar <balintmolnar91@gmail.com>

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

Closes #2423 from baluchicken/KAFKA-4679


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1434b61d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1434b61d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1434b61d

Branch: refs/heads/0.10.2
Commit: 1434b61d5d5511e5297d6ad81e2417db157986aa
Parents: 6cb76b9
Author: Balint Molnar <balintmolnar91@gmail.com>
Authored: Fri Jan 27 19:36:31 2017 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Fri Jan 27 19:40:44 2017 -0800

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/connector/ConnectRecord.java    | 2 --
 .../main/java/org/apache/kafka/connect/connector/Connector.java   | 2 --
 .../java/org/apache/kafka/connect/connector/ConnectorContext.java | 3 ---
 .../src/main/java/org/apache/kafka/connect/connector/Task.java    | 3 ---
 .../java/org/apache/kafka/connect/errors/ConnectException.java    | 2 --
 .../main/java/org/apache/kafka/connect/sink/SinkConnector.java    | 2 --
 .../src/main/java/org/apache/kafka/connect/sink/SinkRecord.java   | 2 --
 .../api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java | 2 --
 .../main/java/org/apache/kafka/connect/sink/SinkTaskContext.java  | 2 --
 .../java/org/apache/kafka/connect/source/SourceConnector.java     | 2 --
 .../main/java/org/apache/kafka/connect/source/SourceRecord.java   | 2 --
 .../src/main/java/org/apache/kafka/connect/source/SourceTask.java | 2 --
 .../java/org/apache/kafka/connect/source/SourceTaskContext.java   | 2 --
 .../src/main/java/org/apache/kafka/connect/storage/Converter.java | 2 --
 .../org/apache/kafka/connect/storage/OffsetStorageReader.java     | 3 ---
 .../main/java/org/apache/kafka/connect/util/ConnectorUtils.java   | 3 ---
 .../java/org/apache/kafka/connect/cli/ConnectDistributed.java     | 2 --
 .../main/java/org/apache/kafka/connect/cli/ConnectStandalone.java | 2 --
 .../src/main/java/org/apache/kafka/connect/runtime/Connect.java   | 2 --
 .../main/java/org/apache/kafka/connect/runtime/WorkerConfig.java  | 2 --
 20 files changed, 44 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
index 6236f7e..f3487c0 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.connector;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.data.Schema;
 
 /**
@@ -28,7 +27,6 @@ import org.apache.kafka.connect.data.Schema;
  * notion of offset, it is not included here because they differ in type.
  * </p>
  */
-@InterfaceStability.Unstable
 public abstract class ConnectRecord<R extends ConnectRecord<R>> {
     private final String topic;
     private final Integer kafkaPartition;

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java
index 1370156..a46babd 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.connector;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.common.config.Config;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigValue;
@@ -42,7 +41,6 @@ import java.util.Map;
  * Tasks.
  * </p>
  */
-@InterfaceStability.Unstable
 public abstract class Connector {
 
     protected ConnectorContext context;

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java
b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java
index c8a06e8..3b887c1 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java
@@ -17,12 +17,9 @@
 
 package org.apache.kafka.connect.connector;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 /**
  * ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.
  */
-@InterfaceStability.Unstable
 public interface ConnectorContext {
     /**
      * Requests that the runtime reconfigure the Tasks for this source. This should be used
to

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java
index 850954d..261134d 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java
@@ -17,8 +17,6 @@
 
 package org.apache.kafka.connect.connector;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 import java.util.Map;
 
 /**
@@ -34,7 +32,6 @@ import java.util.Map;
  * {@link org.apache.kafka.connect.sink.SinkTask}.
  * </p>
  */
-@InterfaceStability.Unstable
 public interface Task {
     /**
      * Get the version of this task. Usually this should be the same as the corresponding
{@link Connector} class's version.

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java
b/connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java
index 1202be3..bdddca0 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java
@@ -18,12 +18,10 @@
 package org.apache.kafka.connect.errors;
 
 import org.apache.kafka.common.KafkaException;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 /**
  * ConnectException is the top-level exception type generated by Kafka Connect and connector
implementations.
  */
-@InterfaceStability.Unstable
 public class ConnectException extends KafkaException {
 
     public ConnectException(String s) {

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
index fbe6975..fd99c93 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
@@ -17,13 +17,11 @@
 
 package org.apache.kafka.connect.sink;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.connector.Connector;
 
 /**
  * SinkConnectors implement the Connector interface to send Kafka data to another system.
  */
-@InterfaceStability.Unstable
 public abstract class SinkConnector extends Connector {
 
     /**

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
index ad1b2d5..894bf0d 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.sink;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.common.record.TimestampType;
 import org.apache.kafka.connect.connector.ConnectRecord;
 import org.apache.kafka.connect.data.Schema;
@@ -30,7 +29,6 @@ import org.apache.kafka.connect.data.Schema;
  * It also includes the {@link TimestampType}, which may be {@link TimestampType#NO_TIMESTAMP_TYPE},
and the relevant
  * timestamp, which may be {@code null}.
  */
-@InterfaceStability.Unstable
 public class SinkRecord extends ConnectRecord<SinkRecord> {
     private final long kafkaOffset;
     private final TimestampType timestampType;

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
index 99a2683..0ea1ecf 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
@@ -18,7 +18,6 @@ package org.apache.kafka.connect.sink;
 
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.connector.Task;
 
 import java.util.Collection;
@@ -52,7 +51,6 @@ import java.util.Map;
   * </ol>
  *
  */
-@InterfaceStability.Unstable
 public abstract class SinkTask implements Task {
 
     /**

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
index 14f13d1..a9d2c05 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
@@ -18,7 +18,6 @@
 package org.apache.kafka.connect.sink;
 
 import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.annotation.InterfaceStability;
 
 import java.util.Map;
 import java.util.Set;
@@ -26,7 +25,6 @@ import java.util.Set;
 /**
  * Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime.
  */
-@InterfaceStability.Unstable
 public interface SinkTaskContext {
     /**
      * Reset the consumer offsets for the given topic partitions. SinkTasks should use this
if they manage offsets

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
index 2ba5139..b67245b 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
@@ -16,14 +16,12 @@
  **/
 package org.apache.kafka.connect.source;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.connector.Connector;
 
 /**
  * SourceConnectors implement the connector interface to pull data from another system and
send
  * it to Kafka.
  */
-@InterfaceStability.Unstable
 public abstract class SourceConnector extends Connector {
 
 }

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
index 444979a..66d7e89 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.source;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.connector.ConnectRecord;
 import org.apache.kafka.connect.data.Schema;
 
@@ -41,7 +40,6 @@ import java.util.Map;
  * "table_name"} and the sourceOffset as a Long containing the timestamp of the row.
  * </p>
  */
-@InterfaceStability.Unstable
 public class SourceRecord extends ConnectRecord<SourceRecord> {
     private final Map<String, ?> sourcePartition;
     private final Map<String, ?> sourceOffset;

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
index c085085..9caca05 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.source;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.connector.Task;
 
 import java.util.List;
@@ -26,7 +25,6 @@ import java.util.Map;
 /**
  * SourceTask is a Task that pulls records from another system for storage in Kafka.
  */
-@InterfaceStability.Unstable
 public abstract class SourceTask implements Task {
 
     protected SourceTaskContext context;

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
index 200fa5f..674f33c 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
@@ -16,14 +16,12 @@
  **/
 package org.apache.kafka.connect.source;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.storage.OffsetStorageReader;
 
 /**
  * SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying
  * runtime.
  */
-@InterfaceStability.Unstable
 public interface SourceTaskContext {
     /**
      * Get the OffsetStorageReader for this SourceTask.

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java b/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java
index c2fda2b..763ce5e 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.storage;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.data.SchemaAndValue;
 
@@ -28,7 +27,6 @@ import java.util.Map;
  * and byte[]. Internally, this likely includes an intermediate step to the format used by
the serialization
  * layer (e.g. JsonNode, GenericRecord, Message).
  */
-@InterfaceStability.Unstable
 public interface Converter {
 
     /**

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
b/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
index 9307c23..10e099c 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
@@ -17,8 +17,6 @@
 
 package org.apache.kafka.connect.storage;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 import java.util.Collection;
 import java.util.Map;
 
@@ -33,7 +31,6 @@ import java.util.Map;
  * {@link org.apache.kafka.connect.data.Schema} other than Array, Map, and Struct.
  * </p>
  */
-@InterfaceStability.Unstable
 public interface OffsetStorageReader {
     /**
      * Get the offset for the specified partition. If the data isn't already available locally,
this

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java b/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java
index 35250eb..6b3eb93 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java
@@ -17,8 +17,6 @@
 
 package org.apache.kafka.connect.util;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
-
 import java.util.ArrayList;
 import java.util.List;
 
@@ -26,7 +24,6 @@ import java.util.List;
  * Utilities that connector implementations might find useful. Contains common building blocks
  * for writing connectors.
  */
-@InterfaceStability.Unstable
 public class ConnectorUtils {
     /**
      * Given a list of elements and a target number of groups, generates list of groups of

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java
index fc957a7..778673b 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.cli;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.connect.runtime.Connect;
@@ -47,7 +46,6 @@ import java.util.Map;
  * instances.
  * </p>
  */
-@InterfaceStability.Unstable
 public class ConnectDistributed {
     private static final Logger log = LoggerFactory.getLogger(ConnectDistributed.class);
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
index c125a33..e3be1c5 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.cli;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.connect.runtime.Connect;
@@ -51,7 +50,6 @@ import java.util.Map;
  * fault tolerant by overriding the settings to use file storage for both.
  * </p>
  */
-@InterfaceStability.Unstable
 public class ConnectStandalone {
     private static final Logger log = LoggerFactory.getLogger(ConnectStandalone.class);
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java
index 86f7f23..219baf0 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.runtime;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.connect.runtime.rest.RestServer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -29,7 +28,6 @@ import java.util.concurrent.atomic.AtomicBoolean;
  * This class ties together all the components of a Kafka Connect process (herder, worker,
  * storage, command interface), managing their lifecycle.
  */
-@InterfaceStability.Unstable
 public class Connect {
     private static final Logger log = LoggerFactory.getLogger(Connect.class);
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/1434b61d/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 fc3fe71..249d41a 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
@@ -17,7 +17,6 @@
 
 package org.apache.kafka.connect.runtime;
 
-import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.common.config.AbstractConfig;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigDef.Importance;
@@ -28,7 +27,6 @@ import java.util.Map;
 /**
  * Common base class providing configuration for Kafka Connect workers, whether standalone
or distributed.
  */
-@InterfaceStability.Unstable
 public class WorkerConfig extends AbstractConfig {
 
     public static final String BOOTSTRAP_SERVERS_CONFIG = "bootstrap.servers";


Mime
View raw message