From 0dc8e089620d925a88aee4730fdd230b330ad41b Mon Sep 17 00:00:00 2001 From: Thomas Vestergaard Trolle Date: Wed, 21 Jul 2021 16:47:16 +0200 Subject: [PATCH 1/2] Add .gitignore To avoid having files accidentally added to the project --- .gitignore | 7 +++++++ 1 file changed, 7 insertions(+) create mode 100644 .gitignore diff --git a/.gitignore b/.gitignore new file mode 100644 index 00000000..011b0874 --- /dev/null +++ b/.gitignore @@ -0,0 +1,7 @@ +#Ignore IntelliJ files +.idea/ +*.iml + +#Ignore Maven files +**/target + From ab0c554fdc9873c9f5729f7090ee0ad545442111 Mon Sep 17 00:00:00 2001 From: Thomas Vestergaard Trolle Date: Wed, 21 Jul 2021 16:53:14 +0200 Subject: [PATCH 2/2] Reduce and update logging It looks like these changes were lost in a merge at some point. Created based on the diff on GitHub. --- .../serializers/GlueSchemaRegistryKafkaSerializer.java | 4 ++-- .../serializers/avro/AWSKafkaAvroSerializer.java | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/GlueSchemaRegistryKafkaSerializer.java b/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/GlueSchemaRegistryKafkaSerializer.java index d4abc4cb..ff5c3a0c 100644 --- a/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/GlueSchemaRegistryKafkaSerializer.java +++ b/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/GlueSchemaRegistryKafkaSerializer.java @@ -98,7 +98,7 @@ public byte[] serialize(String topic, UUID schemaVersionIdFromRegistry = null; if (this.schemaVersionId == null) { - log.info("Schema Version Id is null. Trying to register the schema."); + log.debug("Schema Version Id is null. Trying to register the schema."); schemaVersionIdFromRegistry = glueSchemaRegistrySerializationFacade.getOrRegisterSchemaVersion(prepareInput(data, topic, isKey)); } else { @@ -106,7 +106,7 @@ public byte[] serialize(String topic, } if (schemaVersionIdFromRegistry != null) { - log.info("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry); + log.debug("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry); result = glueSchemaRegistrySerializationFacade.serialize(DataFormat.fromValue(dataFormat), data, schemaVersionIdFromRegistry); } diff --git a/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/avro/AWSKafkaAvroSerializer.java b/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/avro/AWSKafkaAvroSerializer.java index 12b948ce..92b0847c 100644 --- a/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/avro/AWSKafkaAvroSerializer.java +++ b/serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/avro/AWSKafkaAvroSerializer.java @@ -74,7 +74,7 @@ public AWSKafkaAvroSerializer(AwsCredentialsProvider credentialProvider, UUID sc @Override public void configure(@NonNull Map configs, boolean isKey) { - log.info("Configuring Amazon Schema Registry Service using these properties: {}", configs); + log.info("Configuring Amazon Glue Schema Registry Service using these properties: {}", configs); schemaName = GlueSchemaRegistryUtils.getInstance() .getSchemaName(configs); this.isKey = isKey; @@ -101,7 +101,7 @@ public byte[] serialize(String topic, UUID schemaVersionIdFromRegistry = null; if (this.schemaVersionId == null) { - log.info("Schema Version Id is null. Trying to register the schema."); + log.debug("Schema Version Id is null. Trying to register the schema."); schemaVersionIdFromRegistry = glueSchemaRegistrySerializationFacade.getOrRegisterSchemaVersion(prepareInput(data, topic, isKey)); } else { @@ -109,7 +109,7 @@ public byte[] serialize(String topic, } if (schemaVersionIdFromRegistry != null) { - log.info("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry); + log.debug("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry); result = glueSchemaRegistrySerializationFacade.serialize(DATA_FORMAT, data, schemaVersionIdFromRegistry); }