[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect
http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
deleted file mode 100644
index b09cb53..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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.copycat.errors;
-
-/**
- * Indicates the operation tried to create an entity that already exists.
- */
-public class AlreadyExistsException extends CopycatException {
-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/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
deleted file mode 100644
index a8e13a9..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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.copycat.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 CopycatException {
-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/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
deleted file mode 100644
index 75821aa..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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
[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect
http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java
deleted file mode 100644
index b09cb53..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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.copycat.errors;
-
-/**
- * Indicates the operation tried to create an entity that already exists.
- */
-public class AlreadyExistsException extends CopycatException {
-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/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/NotFoundException.java
deleted file mode 100644
index a8e13a9..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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.copycat.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 CopycatException {
-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/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
b/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/RetriableException.java
deleted file mode 100644
index 75821aa..000
---
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/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
