org.apache.flume.source.kafka

Class KafkaSourceUtil

java.lang.Object

org.apache.flume.source.kafka.KafkaSourceUtil

public class KafkaSourceUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSourceUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static kafka.javaapi.consumer.ConsumerConnector	getConsumer(Properties kafkaProps)
static Properties	getKafkaProperties(Context context)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSourceUtil

public KafkaSourceUtil()

Method Detail

getKafkaProperties

public static Properties getKafkaProperties(Context context)

getConsumer

public static kafka.javaapi.consumer.ConsumerConnector getConsumer(Properties kafkaProps)