static Map createSslConfigs()

in src/main/java/com/epam/digital/data/platform/starter/kafka/config/SslUtil.java [35:52]

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

  static Map<String, Object> createSslConfigs(KafkaSslProperties sslProperties) {
    if (!sslProperties.isEnabled()) {
      return Collections.emptyMap();
    }
    return Map.of(
        CommonClientConfigs.SECURITY_PROTOCOL_CONFIG,
        KafkaSslProperties.SECURITY_PROTOCOL,
        SSL_TRUSTSTORE_TYPE_CONFIG,
        sslProperties.getTruststoreType(),
        SSL_KEYSTORE_TYPE_CONFIG,
        sslProperties.getKeystoreType(),
        SSL_TRUSTSTORE_CERTIFICATES_CONFIG,
        sslProperties.getTruststoreCertificate(),
        SSL_KEYSTORE_CERTIFICATE_CHAIN_CONFIG,
        sslProperties.getKeystoreCertificate(),
        SSL_KEYSTORE_KEY_CONFIG,
        sslProperties.getKeystoreKey());
  }