Package com.linkedin.venice.utils

Class KafkaSSLUtils

java.lang.Object

com.linkedin.venice.utils.KafkaSSLUtils

public class KafkaSSLUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
KafkaSSLUtils()

Method Summary

Modifier and Type	Method	Description
static boolean	isKafkaProtocolValid(java.lang.String kafkaProtocol)
static boolean	isKafkaSSLProtocol(PubSubSecurityProtocol kafkaProtocol)
static boolean	isKafkaSSLProtocol(java.lang.String kafkaProtocol)
static boolean	validateAndCopyKafkaSSLConfig(VeniceProperties veniceProperties, java.util.Properties properties)	This function will extract SSL related config if Kafka SSL is enabled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaSSLUtils

public KafkaSSLUtils()

Method Detail

isKafkaProtocolValid

public static boolean isKafkaProtocolValid(java.lang.String kafkaProtocol)

isKafkaSSLProtocol

public static boolean isKafkaSSLProtocol(java.lang.String kafkaProtocol)

isKafkaSSLProtocol

public static boolean isKafkaSSLProtocol(PubSubSecurityProtocol kafkaProtocol)

validateAndCopyKafkaSSLConfig

public static boolean validateAndCopyKafkaSSLConfig(VeniceProperties veniceProperties,
                                                    java.util.Properties properties)

This function will extract SSL related config if Kafka SSL is enabled.

Parameters:

veniceProperties -

properties -

Returns:

whether Kafka SSL is enabled or not