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

Class KafkaInputUtils

java.lang.Object

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

public class KafkaInputUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
KafkaInputUtils()

Method Summary

Modifier and Type	Method	Description
static VeniceCompressor	getCompressor(CompressorFactory compressorFactory, CompressionStrategy strategy, java.lang.String kafkaUrl, java.lang.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 Detail

KafkaInputUtils

public KafkaInputUtils()

Method Detail

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,
                                             java.lang.String kafkaUrl,
                                             java.lang.String topic,
                                             VeniceProperties properties)