public void configure()

in java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverter.java [57:81]

21 lines of code
2 McCabe index (conditional complexity)


    public void configure(Map<String, ?> configs, boolean isKey) {
        this.avroConverterConfig = new AvroConverterConfig(configs);

        TokenCredential tokenCredential = new ClientSecretCredentialBuilder()
            .tenantId((String) this.avroConverterConfig.getProps().get("tenant.id"))
            .clientId((String) this.avroConverterConfig.getProps().get("client.id"))
            .clientSecret((String) this.avroConverterConfig.getProps().get("client.secret")).build();

        if (schemaRegistryClient == null) {
            schemaRegistryClient = new SchemaRegistryClientBuilder()
                .fullyQualifiedNamespace(this.avroConverterConfig.getSchemaRegistryUrl())
                .credential(tokenCredential)
                .clientOptions(new ClientOptions().setApplicationId("KafkaConnectAvro/1.0"))
                .buildAsyncClient();
        }

        serializer = new SchemaRegistryApacheAvroSerializerBuilder()
            .schemaRegistryAsyncClient(schemaRegistryClient)
            .schemaGroup(this.avroConverterConfig.getSchemaGroup()).autoRegisterSchema(true)
            .buildSerializer();

        deserializer = new SchemaRegistryApacheAvroSerializerBuilder()
            .schemaRegistryAsyncClient(schemaRegistryClient)
            .schemaGroup(this.avroConverterConfig.getSchemaGroup()).buildSerializer();
    }