kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: KAFKA-2775: Move exceptions into API package for Kafka Connect.
Date Mon, 09 Nov 2015 18:27:45 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2b04004de -> bc76e6704


KAFKA-2775: Move exceptions into API package for Kafka Connect.

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Gwen Shapira

Closes #457 from ewencp/kafka-2775-exceptions-in-api-package


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

Branch: refs/heads/trunk
Commit: bc76e6704e8f14d59bb5d4fcf9bdf544c9e463bf
Parents: 2b04004
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Mon Nov 9 10:27:18 2015 -0800
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Nov 9 10:27:18 2015 -0800

----------------------------------------------------------------------
 .../connect/errors/AlreadyExistsException.java  | 35 ++++++++++++++++++++
 .../kafka/connect/errors/NotFoundException.java | 35 ++++++++++++++++++++
 .../connect/errors/RetriableException.java      | 35 ++++++++++++++++++++
 .../connect/errors/AlreadyExistsException.java  | 35 --------------------
 .../kafka/connect/errors/NotFoundException.java | 35 --------------------
 .../connect/errors/RetriableException.java      | 35 --------------------
 6 files changed, 105 insertions(+), 105 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
b/connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
new file mode 100644
index 0000000..6fdefdf
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ **/
+
+package org.apache.kafka.connect.errors;
+
+/**
+ * Indicates the operation tried to create an entity that already exists.
+ */
+public class AlreadyExistsException extends ConnectException {
+    public AlreadyExistsException(String s) {
+        super(s);
+    }
+
+    public AlreadyExistsException(String s, Throwable throwable) {
+        super(s, throwable);
+    }
+
+    public AlreadyExistsException(Throwable throwable) {
+        super(throwable);
+    }
+}

http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
b/connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
new file mode 100644
index 0000000..a3bbe91
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ **/
+
+package org.apache.kafka.connect.errors;
+
+/**
+ * Indicates that an operation attempted to modify or delete a connector or task that is
not present on the worker.
+ */
+public class NotFoundException extends ConnectException {
+    public NotFoundException(String s) {
+        super(s);
+    }
+
+    public NotFoundException(String s, Throwable throwable) {
+        super(s, throwable);
+    }
+
+    public NotFoundException(Throwable throwable) {
+        super(throwable);
+    }
+}

http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
b/connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
new file mode 100644
index 0000000..1b5b07a
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ **/
+
+package org.apache.kafka.connect.errors;
+
+/**
+ * An exception that indicates the operation can be reattempted.
+ */
+public class RetriableException extends ConnectException {
+    public RetriableException(String s) {
+        super(s);
+    }
+
+    public RetriableException(String s, Throwable throwable) {
+        super(s, throwable);
+    }
+
+    public RetriableException(Throwable throwable) {
+        super(throwable);
+    }
+}

http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
deleted file mode 100644
index 6fdefdf..0000000
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- **/
-
-package org.apache.kafka.connect.errors;
-
-/**
- * Indicates the operation tried to create an entity that already exists.
- */
-public class AlreadyExistsException extends ConnectException {
-    public AlreadyExistsException(String s) {
-        super(s);
-    }
-
-    public AlreadyExistsException(String s, Throwable throwable) {
-        super(s, throwable);
-    }
-
-    public AlreadyExistsException(Throwable throwable) {
-        super(throwable);
-    }
-}

http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/runtime/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
deleted file mode 100644
index a3bbe91..0000000
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- **/
-
-package org.apache.kafka.connect.errors;
-
-/**
- * Indicates that an operation attempted to modify or delete a connector or task that is
not present on the worker.
- */
-public class NotFoundException extends ConnectException {
-    public NotFoundException(String s) {
-        super(s);
-    }
-
-    public NotFoundException(String s, Throwable throwable) {
-        super(s, throwable);
-    }
-
-    public NotFoundException(Throwable throwable) {
-        super(throwable);
-    }
-}

http://git-wip-us.apache.org/repos/asf/kafka/blob/bc76e670/connect/runtime/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
deleted file mode 100644
index 1b5b07a..0000000
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/errors/RetriableException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- **/
-
-package org.apache.kafka.connect.errors;
-
-/**
- * An exception that indicates the operation can be reattempted.
- */
-public class RetriableException extends ConnectException {
-    public RetriableException(String s) {
-        super(s);
-    }
-
-    public RetriableException(String s, Throwable throwable) {
-        super(s, throwable);
-    }
-
-    public RetriableException(Throwable throwable) {
-        super(throwable);
-    }
-}


Mime
View raw message