public KafkaClientProvider()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [104:121]

• 18 lines of code
• 2 McCabe index (conditional complexity)

    public KafkaClientProvider(
            @Reference EventAdmin eventAdmin, 
            KafkaEndpoint kafkaEndpoint
            ) {
        eventSender = new ExceptionEventSender(eventAdmin);
        kafkaBootstrapServers = requireNonNull(kafkaEndpoint.kafkaBootstrapServers());
        String[] servers = kafkaBootstrapServers.split(",");
        try {
            serverUri = new URI(servers[0]);
        } catch (URISyntaxException e) {
            throw new RuntimeException(e.getMessage(), e);
        }
        requestTimeout = kafkaEndpoint.kafkaRequestTimeout();
        defaultApiTimeout = kafkaEndpoint.kafkaDefaultApiTimeout();
        securityProtocol = kafkaEndpoint.securityProtocol();
        saslMechanism = kafkaEndpoint.saslMechanism();
        saslJaasConfig = kafkaEndpoint.saslJaasConfig();
    }