Package com.linkedin.venice.pubsub.adapter.kafka

Class ApacheKafkaUtils

java.lang.Object

com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaUtils

public class ApacheKafkaUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.kafka.common.header.internals.RecordHeaders	EMPTY_RECORD_HEADERS

Constructor Summary

Constructors

Constructor	Description
ApacheKafkaUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.header.internals.RecordHeaders	convertToKafkaSpecificHeaders(PubSubMessageHeaders headers)
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

Field Details

EMPTY_RECORD_HEADERS

public static final org.apache.kafka.common.header.internals.RecordHeaders EMPTY_RECORD_HEADERS

Constructor Details

ApacheKafkaUtils

public ApacheKafkaUtils()

Method Details

convertToKafkaSpecificHeaders

public static org.apache.kafka.common.header.internals.RecordHeaders convertToKafkaSpecificHeaders(PubSubMessageHeaders headers)

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 not0

isKafkaSSLProtocol

public static boolean isKafkaSSLProtocol(PubSubSecurityProtocol kafkaProtocol)

isKafkaProtocolValid

public static boolean isKafkaProtocolValid(String kafkaProtocol)

isKafkaSSLProtocol

public static boolean isKafkaSSLProtocol(String kafkaProtocol)