File tree Expand file tree Collapse file tree 7 files changed +109
-0
lines changed
src/test/java/io/cdap/plugin/kafka
src/main/java/io/cdap/plugin/kafka/batch/source Expand file tree Collapse file tree 7 files changed +109
-0
lines changed Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
2+ <!--
3+ Copyright © 2025 Cask Data, Inc.
4+
5+ Licensed under the Apache License, Version 2.0 (the "License"); you may not
6+ use this file except in compliance with the License. You may obtain a copy of
7+ the License at
8+
9+ http://www.apache.org/licenses/LICENSE-2.0
10+
11+ Unless required by applicable law or agreed to in writing, software
12+ distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
13+ WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
14+ License for the specific language governing permissions and limitations under
15+ the License.
16+ -->
217<project xmlns =" http://maven.apache.org/POM/4.0.0"
318 xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
419 xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
Original file line number Diff line number Diff line change 1+ /*
2+ * Copyright © 2025 Cask Data, Inc.
3+ *
4+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
5+ * use this file except in compliance with the License. You may obtain a copy of
6+ * the License at
7+ *
8+ * http://www.apache.org/licenses/LICENSE-2.0
9+ *
10+ * Unless required by applicable law or agreed to in writing, software
11+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13+ * License for the specific language governing permissions and limitations under
14+ * the License.
15+ */
16+
117package io .cdap .plugin .kafka ;
218
319import org .apache .kafka .clients .consumer .ConsumerConfig ;
Original file line number Diff line number Diff line change 1+ /*
2+ * Copyright © 2025 Cask Data, Inc.
3+ *
4+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
5+ * use this file except in compliance with the License. You may obtain a copy of
6+ * the License at
7+ *
8+ * http://www.apache.org/licenses/LICENSE-2.0
9+ *
10+ * Unless required by applicable law or agreed to in writing, software
11+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13+ * License for the specific language governing permissions and limitations under
14+ * the License.
15+ */
16+
117package io .cdap .plugin .kafka .source ;
218
319import org .apache .kafka .common .TopicPartition ;
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
2+ <!--
3+ Copyright © 2025 Cask Data, Inc.
4+
5+ Licensed under the Apache License, Version 2.0 (the "License"); you may not
6+ use this file except in compliance with the License. You may obtain a copy of
7+ the License at
8+
9+ http://www.apache.org/licenses/LICENSE-2.0
10+
11+ Unless required by applicable law or agreed to in writing, software
12+ distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
13+ WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
14+ License for the specific language governing permissions and limitations under
15+ the License.
16+ -->
217<project xmlns =" http://maven.apache.org/POM/4.0.0"
318 xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
419 xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
Original file line number Diff line number Diff line change 1+ /*
2+ * Copyright © 2025 Cask Data, Inc.
3+ *
4+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
5+ * use this file except in compliance with the License. You may obtain a copy of
6+ * the License at
7+ *
8+ * http://www.apache.org/licenses/LICENSE-2.0
9+ *
10+ * Unless required by applicable law or agreed to in writing, software
11+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13+ * License for the specific language governing permissions and limitations under
14+ * the License.
15+ */
16+
117package io .cdap .plugin .kafka .batch .source ;
218
319import com .google .common .annotations .VisibleForTesting ;
Original file line number Diff line number Diff line change 1+ /*
2+ * Copyright © 2025 Cask Data, Inc.
3+ *
4+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
5+ * use this file except in compliance with the License. You may obtain a copy of
6+ * the License at
7+ *
8+ * http://www.apache.org/licenses/LICENSE-2.0
9+ *
10+ * Unless required by applicable law or agreed to in writing, software
11+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13+ * License for the specific language governing permissions and limitations under
14+ * the License.
15+ */
16+
117package io .cdap .plugin .kafka .batch .source ;
218
319import java .io .Closeable ;
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
2+ <!--
3+ Copyright © 2025 Cask Data, Inc.
4+
5+ Licensed under the Apache License, Version 2.0 (the "License"); you may not
6+ use this file except in compliance with the License. You may obtain a copy of
7+ the License at
8+
9+ http://www.apache.org/licenses/LICENSE-2.0
10+
11+ Unless required by applicable law or agreed to in writing, software
12+ distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
13+ WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
14+ License for the specific language governing permissions and limitations under
15+ the License.
16+ -->
217<project xmlns =" http://maven.apache.org/POM/4.0.0"
318 xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
419 xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
You can’t perform that action at this time.
0 commit comments