io.druid.firehose.kafka

Class KafkaEightSimpleConsumerFirehoseFactory

java.lang.Object

io.druid.firehose.kafka.KafkaEightSimpleConsumerFirehoseFactory

All Implemented Interfaces:

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

public class KafkaEightSimpleConsumerFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactoryV2<io.druid.data.input.ByteBufferInputRowParser>

Constructor Summary

Constructors

Constructor and Description
KafkaEightSimpleConsumerFirehoseFactory(List<String> brokerList, List<Integer> partitionIdList, String clientId, String feed, Integer queueBufferLength, Boolean resetOffsetToEarliest)

Method Summary

Modifier and Type	Method and Description
io.druid.data.input.FirehoseV2	connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser, Object lastCommit)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEightSimpleConsumerFirehoseFactory

public KafkaEightSimpleConsumerFirehoseFactory(List<String> brokerList,
                                               List<Integer> partitionIdList,
                                               String clientId,
                                               String feed,
                                               Integer queueBufferLength,
                                               Boolean resetOffsetToEarliest)

Method Detail

connect

public io.druid.data.input.FirehoseV2 connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser,
                                              Object lastCommit)
                                       throws IOException

Specified by:

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

Throws:

IOException