Package com.linkedin.venice.hadoop.input.kafka

Class KafkaInputUtils

java.lang.Object

com.linkedin.venice.hadoop.input.kafka.KafkaInputUtils

public class KafkaInputUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaInputUtils()

Method Summary

Modifier and Type	Method	Description
static VeniceCompressor	getCompressor(CompressorFactory compressorFactory, CompressionStrategy strategy, String kafkaUrl, String topic, VeniceProperties properties)
static VeniceProperties	getConsumerProperties(org.apache.hadoop.mapred.JobConf config)
static KafkaValueSerializer	getKafkaValueSerializer(org.apache.hadoop.mapred.JobConf config)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaInputUtils

public KafkaInputUtils()

Method Details

getConsumerProperties

public static VeniceProperties getConsumerProperties(org.apache.hadoop.mapred.JobConf config)

getKafkaValueSerializer

public static KafkaValueSerializer getKafkaValueSerializer(org.apache.hadoop.mapred.JobConf config)

getCompressor

public static VeniceCompressor getCompressor(CompressorFactory compressorFactory,
 CompressionStrategy strategy,
 String kafkaUrl,
 String topic,
 VeniceProperties properties)