public void configure()

in java/json/src/main/java/com/microsoft/azure/schemaregistry/kafka/json/KafkaJsonSerializer.java [52:75]

• 21 lines of code
• 3 McCabe index (conditional complexity)

    public void configure(Map<String, ?> props, boolean isKey) {
        KafkaJsonSerializerConfig config = new KafkaJsonSerializerConfig((Map<String, Object>) props);

        this.autoRegisterSchemas = config.getAutoRegisterSchemas();
        this.schemaGroup = config.getSchemaGroup();

        TokenCredential tokenCredential;
        tokenCredential = config.getCredential();
        if (tokenCredential == null && config.createDefaultAzureCredential()) {
            tokenCredential = new DefaultAzureCredentialBuilder().build();
        } else {
            throw new RuntimeException(
                "TokenCredential not created for serializer. "
                + "Please provide a TokenCredential in config or set "
                + "\"use.azure.credential\" to true."
            );
        }

        this.client = new SchemaRegistryClientBuilder()
        .fullyQualifiedNamespace(config.getSchemaRegistryUrl())
        .credential(tokenCredential)
        .clientOptions(new ClientOptions().setApplicationId("java-json-kafka-ser-1.0"))
        .buildClient();
    }