Backport pull #1340 to v1.x

pom.xml

@@ -26,6 +26,7 @@
 
   <properties>
     <aws-java-sdk.version>1.12.681</aws-java-sdk.version>
+    <protobuf.version>3.23.4</protobuf.version>
     <sqlite4java.version>1.0.392</sqlite4java.version>
     <sqlite4java.native>libsqlite4java</sqlite4java.native>
     <sqlite4java.libpath>${project.build.directory}/test-lib</sqlite4java.libpath>
@@ -60,7 +61,7 @@
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java</artifactId>
-      <version>3.23.4</version>
+      <version>${protobuf.version}</version>
     </dependency>
     <dependency>
       <groupId>org.apache.commons</groupId>
@@ -149,6 +150,13 @@
   </developers>
 
   <build>
+    <extensions>
+      <extension>
+        <groupId>kr.motd.maven</groupId>
+        <artifactId>os-maven-plugin</artifactId>
+        <version>1.6.0</version>
+      </extension>
+    </extensions>
     <pluginManagement>
       <plugins>
         <plugin>
@@ -165,6 +173,21 @@
     </pluginManagement>
 
     <plugins>
+      <plugin>
+        <groupId>org.xolstice.maven.plugins</groupId>
+        <artifactId>protobuf-maven-plugin</artifactId>
+        <version>0.6.1</version>
+        <executions>
+          <execution>
+            <goals>
+              <goal>compile</goal>
+            </goals>
+          </execution>
+        </executions>
+        <configuration>
+          <protocArtifact>com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier}</protocArtifact>
+        </configuration>
+      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-surefire-plugin</artifactId>

src/main/proto/messages.proto

@@ -0,0 +1,23 @@
+// Copied from amazon-kinesis-producer/aws/kinesis/protobuf/messages.proto with
+// subset of messages that KCL needs
+
+syntax = "proto2";
+package com.amazonaws.services.kinesis.clientlibrary.types;
+
+message Tag {
+  required string key = 1;
+  optional string value = 2;
+}
+
+message Record {
+  required uint64 partition_key_index = 1;
+  optional uint64 explicit_hash_key_index = 2;
+  required bytes data = 3;
+  repeated Tag tags = 4;
+}
+
+message AggregatedRecord {
+  repeated string partition_key_table = 1;
+  repeated string explicit_hash_key_table = 2;
+  repeated Record records = 3;
+}