diff --git a/amazon-kinesis-client/pom.xml b/amazon-kinesis-client/pom.xml index 5b980803..979ffd08 100644 --- a/amazon-kinesis-client/pom.xml +++ b/amazon-kinesis-client/pom.xml @@ -77,12 +77,12 @@ software.amazon.glue schema-registry-serde - 1.1.1 + 1.1.3 software.amazon.glue schema-registry-common - 1.1.1 + 1.1.3 com.google.guava diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java index 0418a00a..d6f96b76 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java @@ -14,11 +14,13 @@ import java.util.List; */ @Slf4j public class SchemaRegistryDecoder { + private static final String USER_AGENT_APP_NAME = "kcl"; private final GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer; public SchemaRegistryDecoder( GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer) { this.glueSchemaRegistryDeserializer = glueSchemaRegistryDeserializer; + this.glueSchemaRegistryDeserializer.overrideUserAgentApp(USER_AGENT_APP_NAME); } /**