serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/GlueSchemaRegistryKafkaSerializer.java [87:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            GlueSchemaRegistryConfiguration glueSchemaRegistryConfiguration = new GlueSchemaRegistryConfiguration(configs);
            if (this.userAgentApp == null) {
                //Set it to kafka if not set by upstream serializers / deserializers
                this.userAgentApp = UserAgents.KAFKA;
            }
            glueSchemaRegistryConfiguration.setUserAgentApp(this.userAgentApp);
            glueSchemaRegistrySerializationFacade = GlueSchemaRegistrySerializationFacade.builder()
                    .glueSchemaRegistryConfiguration(glueSchemaRegistryConfiguration)
                    .credentialProvider(credentialProvider)
                    .build();
        }
    }

    @Override
    public byte[] serialize(String topic,
                            Object data) {
        byte[] result = null;

        if (null == data) {
            return null;
        }

        UUID schemaVersionIdFromRegistry = null;
        if (this.schemaVersionId == null) {
            log.debug("Schema Version Id is null. Trying to register the schema.");
            schemaVersionIdFromRegistry =
                    glueSchemaRegistrySerializationFacade.getOrRegisterSchemaVersion(prepareInput(data, topic, isKey));
        } else {
            schemaVersionIdFromRegistry = this.schemaVersionId;
        }

        if (schemaVersionIdFromRegistry != null) {
            log.debug("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



serializer-deserializer/src/main/java/com/amazonaws/services/schemaregistry/serializers/avro/AWSKafkaAvroSerializer.java [90:121]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        GlueSchemaRegistryConfiguration glueSchemaRegistryConfiguration = new GlueSchemaRegistryConfiguration(configs);
        if (this.userAgentApp == null) {
            //Set it to kafka if not set by upstream serializers / deserializers
            this.userAgentApp = UserAgents.KAFKA;
        }
        glueSchemaRegistryConfiguration.setUserAgentApp(this.userAgentApp);
        glueSchemaRegistrySerializationFacade = GlueSchemaRegistrySerializationFacade.builder()
            .glueSchemaRegistryConfiguration(glueSchemaRegistryConfiguration)
                .credentialProvider(credentialProvider)
                .build();
    }

    @Override
    public byte[] serialize(String topic,
                            Object data) {
        byte[] result = null;

        if (null == data) {
            return null;
        }

        UUID schemaVersionIdFromRegistry = null;
        if (this.schemaVersionId == null) {
            log.debug("Schema Version Id is null. Trying to register the schema.");
            schemaVersionIdFromRegistry =
                    glueSchemaRegistrySerializationFacade.getOrRegisterSchemaVersion(prepareInput(data, topic, isKey));
        } else {
            schemaVersionIdFromRegistry = this.schemaVersionId;
        }

        if (schemaVersionIdFromRegistry != null) {
            log.debug("Schema Version Id received from the from schema registry: {}", schemaVersionIdFromRegistry);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -