diff --git a/kafka-plugins-client/pom.xml b/kafka-plugins-client/pom.xml index 1773669..05a110f 100644 --- a/kafka-plugins-client/pom.xml +++ b/kafka-plugins-client/pom.xml @@ -1,4 +1,19 @@ + diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaTestCommon.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaTestCommon.java index 639a481..9ae6890 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaTestCommon.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaTestCommon.java @@ -1,3 +1,19 @@ +/* + * Copyright © 2025 Cask Data, Inc. + * + * Licensed 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 io.cdap.plugin.kafka; import org.apache.kafka.clients.consumer.ConsumerConfig; diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/source/KafkaStreamingSourceUtilTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/source/KafkaStreamingSourceUtilTest.java index 39fa9b5..4f8c2d6 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/source/KafkaStreamingSourceUtilTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/source/KafkaStreamingSourceUtilTest.java @@ -1,3 +1,19 @@ +/* + * Copyright © 2025 Cask Data, Inc. + * + * Licensed 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 io.cdap.plugin.kafka.source; import org.apache.kafka.common.TopicPartition; diff --git a/kafka-plugins-common/pom.xml b/kafka-plugins-common/pom.xml index 8f7834d..0042193 100644 --- a/kafka-plugins-common/pom.xml +++ b/kafka-plugins-common/pom.xml @@ -1,4 +1,19 @@ + diff --git a/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaBatchConfig.java b/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaBatchConfig.java index 9168bf6..9972242 100644 --- a/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaBatchConfig.java +++ b/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaBatchConfig.java @@ -1,3 +1,19 @@ +/* + * Copyright © 2025 Cask Data, Inc. + * + * Licensed 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 io.cdap.plugin.kafka.batch.source; import com.google.common.annotations.VisibleForTesting; diff --git a/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaReader.java b/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaReader.java index bfd602c..a3d4561 100644 --- a/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaReader.java +++ b/kafka-plugins-common/src/main/java/io/cdap/plugin/kafka/batch/source/KafkaReader.java @@ -1,3 +1,19 @@ +/* + * Copyright © 2025 Cask Data, Inc. + * + * Licensed 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 io.cdap.plugin.kafka.batch.source; import java.io.Closeable; diff --git a/pom.xml b/pom.xml index c7b9243..04552f9 100644 --- a/pom.xml +++ b/pom.xml @@ -1,4 +1,19 @@ +