public static boolean isSSLEnabled()

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

• 7 lines of code
• 3 McCabe index (conditional complexity)

  public static boolean isSSLEnabled(Properties kafkaProps) {
    String securityProtocol =
        kafkaProps.getProperty(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG);

    return securityProtocol != null &&
        (securityProtocol.equals(SecurityProtocol.SSL.name) ||
            securityProtocol.equals(SecurityProtocol.SASL_SSL.name));
  }