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
All Methods Static Methods Concrete Methods Modifier and Type Method Description static boolean
isKafkaProtocolValid(java.lang.String kafkaProtocol)
Right now, Venice only supports two Kafka protocols:SecurityProtocol.PLAINTEXT
SecurityProtocol.SSL
static boolean
isKafkaSSLProtocol(java.lang.String kafkaProtocol)
static boolean
isKafkaSSLProtocol(org.apache.kafka.common.protocol.SecurityProtocol kafkaProtocol)
static boolean
validateAndCopyKafkaSSLConfig(VeniceProperties veniceProperties, java.util.Properties properties)
This function will extract SSL related config if Kafka SSL is enabled.
-
-
-
Method Detail
-
isKafkaProtocolValid
public static boolean isKafkaProtocolValid(java.lang.String kafkaProtocol)
Right now, Venice only supports two Kafka protocols:SecurityProtocol.PLAINTEXT
SecurityProtocol.SSL
- Parameters:
kafkaProtocol
-- Returns:
-
isKafkaSSLProtocol
public static boolean isKafkaSSLProtocol(java.lang.String kafkaProtocol)
-
isKafkaSSLProtocol
public static boolean isKafkaSSLProtocol(org.apache.kafka.common.protocol.SecurityProtocol 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
-
-