private AdminClient kafkaAdminClient()

in src/main/java/com/epam/digital/data/platform/starter/restapi/config/KafkaConfig.java [158:165]

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

  private AdminClient kafkaAdminClient() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrap());
    if (kafkaProperties.getSsl().isEnabled()) {
      props.putAll(createSslProperties());
    }
    return AdminClient.create(props);
  }