Class 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.
      • 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)
        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