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

Emit Glue Schema Registry usage metrics

Browse source
This commit is contained in:
Ravindranath Kakarla 2021-09-21 23:45:29 -07:00
parent e73a8a9f3a
commit 5ce940a7b7
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
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.1</version> <version>1.1.3</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.1</version> <version>1.1.3</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.google.guava</groupId> <groupId>com.google.guava</groupId>

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

@ -14,11 +14,13 @@ import java.util.List;
*/ */
@Slf4j @Slf4j
public class SchemaRegistryDecoder { public class SchemaRegistryDecoder {
private static final String USER_AGENT_APP_NAME = "kcl";
private final GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer; private final GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer;
public SchemaRegistryDecoder( public SchemaRegistryDecoder(
GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer) { GlueSchemaRegistryDeserializer glueSchemaRegistryDeserializer) {
this.glueSchemaRegistryDeserializer = glueSchemaRegistryDeserializer; this.glueSchemaRegistryDeserializer = glueSchemaRegistryDeserializer;
this.glueSchemaRegistryDeserializer.overrideUserAgentApp(USER_AGENT_APP_NAME);
} }
/** /**