io.druid.firehose.kafka

Class KafkaEightFirehoseFactory

java.lang.Object

io.druid.firehose.kafka.KafkaEightFirehoseFactory

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
KafkaEightFirehoseFactory(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)
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

KafkaEightFirehoseFactory

public KafkaEightFirehoseFactory(Properties consumerProps,
                         String feed,
                         io.druid.data.input.ByteBufferInputRowParser parser)

Method Detail

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

getParser

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

Specified by:

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