You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ce...@apache.org on 2022/12/13 14:39:18 UTC

[kafka] branch trunk updated: KAFKA-13881: Add Connect package infos (#12937)

This is an automated email from the ASF dual-hosted git repository.

cegerton pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 526af63cfe5 KAFKA-13881: Add Connect package infos (#12937)
526af63cfe5 is described below

commit 526af63cfe57eccb93d9cb79542e87c16b669a15
Author: Greg Harris <gr...@aiven.io>
AuthorDate: Tue Dec 13 06:39:10 2022 -0800

    KAFKA-13881: Add Connect package infos (#12937)
    
    Reviewers: Chris Egerton <ch...@aiven.io>
---
 .../kafka/connect/components/package-info.java     | 20 +++++++++++++++++++
 .../kafka/connect/connector/package-info.java      | 20 +++++++++++++++++++
 .../connect/connector/policy/package-info.java     | 23 ++++++++++++++++++++++
 .../apache/kafka/connect/data/package-info.java    | 20 +++++++++++++++++++
 .../apache/kafka/connect/errors/package-info.java  | 20 +++++++++++++++++++
 .../apache/kafka/connect/header/package-info.java  | 20 +++++++++++++++++++
 .../apache/kafka/connect/health/package-info.java  | 21 ++++++++++++++++++++
 .../apache/kafka/connect/rest/package-info.java    | 20 +++++++++++++++++++
 .../apache/kafka/connect/sink/package-info.java    | 20 +++++++++++++++++++
 .../apache/kafka/connect/source/package-info.java  | 20 +++++++++++++++++++
 .../apache/kafka/connect/storage/package-info.java | 20 +++++++++++++++++++
 .../kafka/connect/transforms/package-info.java     | 20 +++++++++++++++++++
 .../transforms/predicates/package-info.java        | 20 +++++++++++++++++++
 .../apache/kafka/connect/util/package-info.java    | 20 +++++++++++++++++++
 14 files changed, 284 insertions(+)

diff --git a/connect/api/src/main/java/org/apache/kafka/connect/components/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/components/package-info.java
new file mode 100644
index 00000000000..9f32051ae23
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/components/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides common interfaces used to describe pluggable components.
+ */
+package org.apache.kafka.connect.components;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/package-info.java
new file mode 100644
index 00000000000..4a631944c9b
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides interfaces for Connector and Task implementations.
+ */
+package org.apache.kafka.connect.connector;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/policy/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/policy/package-info.java
new file mode 100644
index 00000000000..46581216c75
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/policy/package-info.java
@@ -0,0 +1,23 @@
+/*
+ * 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.
+ */
+/**
+ * Provides pluggable interfaces for policies controlling how users can configure connectors.
+ * For example, the
+ * {@link org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy ConnectorClientConfigOverridePolicy}
+ * interface can be used to control which Kafka client properties can be overridden on a per-connector basis.
+ */
+package org.apache.kafka.connect.connector.policy;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/data/package-info.java
new file mode 100644
index 00000000000..22017598d02
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/data/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides classes for representing data and schemas handled by Connect.
+ */
+package org.apache.kafka.connect.data;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/errors/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/errors/package-info.java
new file mode 100644
index 00000000000..7df20b603f9
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/errors/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides common exception classes for Connect, used by the framework and plugins to communicate failures.
+ */
+package org.apache.kafka.connect.errors;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/header/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/header/package-info.java
new file mode 100644
index 00000000000..5f6114cc755
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/header/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides an API for application-defined metadata attached to Connect records.
+ */
+package org.apache.kafka.connect.header;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/health/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/health/package-info.java
new file mode 100644
index 00000000000..da1697836fe
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/health/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * 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.
+ */
+/**
+ * Provides an API for describing the state of a running Connect cluster to
+ * {@link org.apache.kafka.connect.rest.ConnectRestExtension} instances.
+ */
+package org.apache.kafka.connect.health;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/rest/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/rest/package-info.java
new file mode 100644
index 00000000000..1c72f4f14ab
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/rest/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides a pluggable interface for altering the behavior of the Connect REST API.
+ */
+package org.apache.kafka.connect.rest;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/sink/package-info.java
new file mode 100644
index 00000000000..1351154c8ad
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/sink/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides an API for implementing sink connectors which write Kafka records to external applications.
+ */
+package org.apache.kafka.connect.sink;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/source/package-info.java
new file mode 100644
index 00000000000..b2ad0152206
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/source/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides an API for implementing source connectors which read data from external applications into Kafka.
+ */
+package org.apache.kafka.connect.source;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/storage/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/storage/package-info.java
new file mode 100644
index 00000000000..26ae3d207ae
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/storage/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides pluggable interfaces and some implementations for (de)serializing data to and from Kafka
+ */
+package org.apache.kafka.connect.storage;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/transforms/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/transforms/package-info.java
new file mode 100644
index 00000000000..30505a8a2e1
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/transforms/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides a pluggable interface for altering data which is being moved by Connect.
+ */
+package org.apache.kafka.connect.transforms;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/package-info.java
new file mode 100644
index 00000000000..2594d20a7c6
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides a pluggable interface for describing when a {@link org.apache.kafka.connect.transforms.Transformation} should be applied to a record.
+ */
+package org.apache.kafka.connect.transforms.predicates;
\ No newline at end of file
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/util/package-info.java b/connect/api/src/main/java/org/apache/kafka/connect/util/package-info.java
new file mode 100644
index 00000000000..a7945f18cad
--- /dev/null
+++ b/connect/api/src/main/java/org/apache/kafka/connect/util/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+/**
+ * Provides common utilities that can be used in component implementations.
+ */
+package org.apache.kafka.connect.util;
\ No newline at end of file