io.druid.firehose.kafka

Class KafkaSevenFirehoseFactory

java.lang.Object

io.druid.firehose.kafka.KafkaSevenFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.ByteBufferInputRowParser>

public class KafkaSevenFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.ByteBufferInputRowParser>

Constructor Summary

Constructors

Constructor and Description
KafkaSevenFirehoseFactory(Properties consumerProps, String feed)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser)
Properties	getConsumerProps()
String	getFeed()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSevenFirehoseFactory

public KafkaSevenFirehoseFactory(Properties consumerProps,
                         String feed)

Method Detail

getConsumerProps

public Properties getConsumerProps()

getFeed

public String getFeed()

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.ByteBufferInputRowParser>

Throws:

IOException