org.apache.flume.source.kafka
Class KafkaSourceUtil

java.lang.Object
  extended by org.apache.flume.source.kafka.KafkaSourceUtil

public class KafkaSourceUtil
extends Object


Constructor Summary
KafkaSourceUtil()
           
 
Method Summary
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)


Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.