KafkaSSLUtils (venice API)

java.lang.Object

com.linkedin.venice.utils.KafkaSSLUtils

public class KafkaSSLUtils extends Object

Constructor Summary

Constructors

Constructor

Description

KafkaSSLUtils()
Method Summary

Modifier and Type

Method

Description

static boolean

isKafkaProtocolValid(String kafkaProtocol)

static boolean

isKafkaSSLProtocol(PubSubSecurityProtocol kafkaProtocol)

static boolean

isKafkaSSLProtocol(String kafkaProtocol)

static boolean

validateAndCopyKafkaSSLConfig(VeniceProperties veniceProperties, 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 Details
- KafkaSSLUtils
  
  public KafkaSSLUtils()
Method Details
- isKafkaProtocolValid
  
  public static boolean isKafkaProtocolValid(String kafkaProtocol)
- isKafkaSSLProtocol
  
  public static boolean isKafkaSSLProtocol(String kafkaProtocol)
- isKafkaSSLProtocol
  
  public static boolean isKafkaSSLProtocol(PubSubSecurityProtocol kafkaProtocol)
- validateAndCopyKafkaSSLConfig
  
  public static boolean validateAndCopyKafkaSSLConfig(VeniceProperties veniceProperties, 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