in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [104:121]
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();
}