luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Append KCL version to the app string.

Browse source
This commit is contained in:
Ravindranath Kakarla 2021-09-29 15:47:55 -07:00
parent 5ce940a7b7
commit 7c5492e6f8
3 changed files with 48 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
amazon-kinesis-client/pom.xml
View file

@ -77,12 +77,12 @@
<dependency> <dependency>
<groupId>software.amazon.glue</groupId> <groupId>software.amazon.glue</groupId>
<artifactId>schema-registry-serde</artifactId> <artifactId>schema-registry-serde</artifactId>
<version>1.1.3</version> <version>1.1.4</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>software.amazon.glue</groupId> <groupId>software.amazon.glue</groupId>
<artifactId>schema-registry-common</artifactId> <artifactId>schema-registry-common</artifactId>
<version>1.1.3</version> <version>1.1.4</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.google.guava</groupId> <groupId>com.google.guava</groupId>
@ -324,6 +324,45 @@
</execution> </execution>
</executions> </executions>
</plugin> </plugin>
<!-- Required for generating maven version as a Java class for runtime access -->
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>templating-maven-plugin</artifactId>
<version>1.0.0</version>
<executions>
<execution>
<id>generate-version-class</id>
<goals>
<goal>filter-sources</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-resources-plugin</artifactId>
<executions>
<execution>
<id>copy-dist</id>
<phase>prepare-package</phase>
<goals>
<goal>copy-resources</goal>
</goals>
<configuration>
<outputDirectory>${project.build.outputDirectory}</outputDirectory>
<resources>
<resource>
<directory>${project.basedir}/target/generated-sources/java-templates/</directory>
<filtering>false</filtering>
<excludes>
</excludes>
</resource>
</resources>
</configuration>
</execution>
</executions>
</plugin>
</plugins> </plugins>
</build> </build>

5
amazon-kinesis-client/src/main/java-templates/KinesisClientLibraryPackage.java Normal file
View file

@ -0,0 +1,5 @@
package software.amazon.kinesis.common;
public final class KinesisClientLibraryPackage {
public static final String VERSION = "${project.version}";
}

3
amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java
View file

@ -3,6 +3,7 @@ package software.amazon.kinesis.schemaregistry;
import com.amazonaws.services.schemaregistry.common.Schema; import com.amazonaws.services.schemaregistry.common.Schema;
import com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializer; import com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializer;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import software.amazon.kinesis.common.KinesisClientLibraryPackage;
import software.amazon.kinesis.retrieval.KinesisClientRecord; import software.amazon.kinesis.retrieval.KinesisClientRecord;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
@ -14,7 +15,7 @@ import java.util.List;
*/ */
@Slf4j @Slf4j
public class SchemaRegistryDecoder { public class SchemaRegistryDecoder {
private static final String USER_AGENT_APP_NAME = "kcl"; private static final String USER_AGENT_APP_NAME = "kcl" + "-" + KinesisClientLibraryPackage.VERSION;
private final GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer; private final GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer;
public SchemaRegistryDecoder( public SchemaRegistryDecoder(