Apicurio · jsenko · Nov 6, 2023 · Oct 31, 2023 · Nov 6, 2023
diff --git a/avro-bean/src/main/java/io/apicurio/registry/examples/avro/bean/AvroBeanExample.java b/avro-bean/src/main/java/io/apicurio/registry/examples/avro/bean/AvroBeanExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/.../src/main/java/io/apicurio/registry/examples/confluent/serdes/ConfluentSerdesExample.java b/.../src/main/java/io/apicurio/registry/examples/confluent/serdes/ConfluentSerdesExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/custom-resolver/src/main/java/io/apicurio/registry/examples/custom/resolver/Config.java b/custom-resolver/src/main/java/io/apicurio/registry/examples/custom/resolver/Config.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...ver/src/main/java/io/apicurio/registry/examples/custom/resolver/CustomSchemaResolver.java b/...ver/src/main/java/io/apicurio/registry/examples/custom/resolver/CustomSchemaResolver.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/.../main/java/io/apicurio/registry/examples/custom/resolver/CustomSchemaResolverExample.java b/.../main/java/io/apicurio/registry/examples/custom/resolver/CustomSchemaResolverExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/custom-strategy/src/main/java/io/apicurio/registry/examples/custom/strategy/Config.java b/custom-strategy/src/main/java/io/apicurio/registry/examples/custom/strategy/Config.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...gy/src/main/java/io/apicurio/registry/examples/custom/strategy/CustomStrategyExample.java b/...gy/src/main/java/io/apicurio/registry/examples/custom/strategy/CustomStrategyExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/mix-avro/src/main/java/io/apicurio/registry/examples/mix/avro/MixAvroExample.java b/mix-avro/src/main/java/io/apicurio/registry/examples/mix/avro/MixAvroExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/pom.xml b/pom.xml
@@ -52,6 +52,7 @@
         <module>rest-client-downstream</module>
         <module>serdes-with-references</module>
         <module>protobuf-validation</module>
+        <module>tools/kafkasql-topic-import</module>
         <!--<module>camel-quarkus-kafka</module>-->
     </modules>
 

diff --git a/...bean/src/main/java/io/apicurio/registry/examples/simple/protobuf/ProtobufBeanExample.java b/...bean/src/main/java/io/apicurio/registry/examples/simple/protobuf/ProtobufBeanExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...rc/main/java/io/apicurio/registry/examples/simple/protobuf/ProtobufFindLatestExample.java b/...rc/main/java/io/apicurio/registry/examples/simple/protobuf/ProtobufFindLatestExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/simple-avro-downstream/src/main/java/avro/SimpleAvroExample.java b/simple-avro-downstream/src/main/java/avro/SimpleAvroExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...src/main/java/io/apicurio/registry/examples/simple/avro/maven/SimpleAvroMavenExample.java b/...src/main/java/io/apicurio/registry/examples/simple/avro/maven/SimpleAvroMavenExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/simple-avro/src/main/java/io/apicurio/registry/examples/simple/avro/SimpleAvroExample.java b/simple-avro/src/main/java/io/apicurio/registry/examples/simple/avro/SimpleAvroExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...json/src/main/java/io/apicurio/registry/examples/simple/json/SimpleJsonSchemaExample.java b/...json/src/main/java/io/apicurio/registry/examples/simple/json/SimpleJsonSchemaExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...uf/src/main/java/io/apicurio/registry/examples/simple/protobuf/SimpleProtobufExample.java b/...uf/src/main/java/io/apicurio/registry/examples/simple/protobuf/SimpleProtobufExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/...tion/src/main/java/io/apicurio/registry/examples/simple/json/SimpleValidationExample.java b/...tion/src/main/java/io/apicurio/registry/examples/simple/json/SimpleValidationExample.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 JBoss Inc
+ * Copyright 2023 JBoss Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

diff --git a/tools/kafkasql-topic-import/pom.xml b/tools/kafkasql-topic-import/pom.xml
@@ -0,0 +1,94 @@
+<?xml version="1.0"?>
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
+         xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>io.apicurio</groupId>
+        <artifactId>apicurio-registry-examples</artifactId>
+        <version>2.4.3.Final</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>apicurio-registry-tools-kafkasql-topic-import</artifactId>
+    <packaging>jar</packaging>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.28</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>2.15.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.15.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>3.2.3</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>32.1.3-jre</version>
+        </dependency>
+
+        <dependency>
+            <groupId>info.picocli</groupId>
+            <artifactId>picocli</artifactId>
+            <version>4.7.5</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>2.0.9</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>2.0.9</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <mainClass>io.apicurio.registry.tools.kafkasqltopicimport.Main</mainClass>
+                        </manifest>
+                    </archive>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-assembly</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/...l-topic-import/src/main/java/io/apicurio/registry/tools/kafkasqltopicimport/Envelope.java b/...l-topic-import/src/main/java/io/apicurio/registry/tools/kafkasqltopicimport/Envelope.java
@@ -0,0 +1,53 @@
+/*
+ * Copyright 2020 Red Hat
+ *
+ * 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.apicurio.registry.tools.kafkasqltopicimport;
+
+import lombok.*;
+
+import java.util.List;
+
+
+/**
+ * @author Jakub Senko <em>[email protected]</em>
+ */
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Getter
+@Setter
+@EqualsAndHashCode
+@ToString
+public class Envelope {
+
+    private String topic;
+
+    private Integer partition;
+
+    private Long offset;
+
+    private String tstype;
+
+    private Long ts;
+
+    private Long broker;
+
+    private List<String> headers;
+
+    private String key;
+
+    private String payload;
+}