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, io.druid.data.input.ByteBufferInputRowParser parser)

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()
io.druid.data.input.ByteBufferInputRowParser	getParser()

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,
                         io.druid.data.input.ByteBufferInputRowParser parser)

Method Detail

getConsumerProps

public Properties getConsumerProps()

getFeed

public String getFeed()

getParser

public io.druid.data.input.ByteBufferInputRowParser getParser()

Specified by:

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

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