Package com.linkedin.venice.utils

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