public static void addGlobalSSLParameters()

in flume-shared/flume-shared-kafka/src/main/java/org/apache/flume/shared/kafka/KafkaSSLUtil.java [42:57]

16 lines of code
2 McCabe index (conditional complexity)


  public static void addGlobalSSLParameters(Properties kafkaProps) {
    if (isSSLEnabled(kafkaProps)) {
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, SSLUtil.getGlobalKeystorePath());
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, SSLUtil.getGlobalKeystorePassword());
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_KEYSTORE_TYPE_CONFIG, SSLUtil.getGlobalKeystoreType(null));
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, SSLUtil.getGlobalTruststorePath());
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, SSLUtil.getGlobalTruststorePassword());
      addGlobalSSLParameter(kafkaProps,
          SslConfigs.SSL_TRUSTSTORE_TYPE_CONFIG, SSLUtil.getGlobalTruststoreType(null));
    }
  }