private AdminClient kafkaAdminClient()

in src/main/java/com/epam/digital/data/platform/starter/kafka/config/KafkaAdminConfig.java [43:48]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  private AdminClient kafkaAdminClient() {
    Map<String, Object> props = new HashMap<>();
    props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrap());
    props.putAll(SslUtil.createSslConfigs(kafkaProperties.getSsl()));
    return AdminClient.create(props);
  }