io.druid.firehose.kafka

Class KafkaEightSimpleConsumerFirehoseFactory

java.lang.Object

io.druid.firehose.kafka.KafkaEightSimpleConsumerFirehoseFactory

All Implemented Interfaces:

FirehoseFactoryV2<ByteBufferInputRowParser>

public class KafkaEightSimpleConsumerFirehoseFactory
extends Object
implements FirehoseFactoryV2<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
FirehoseV2	connect(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 FirehoseV2 connect(ByteBufferInputRowParser firehoseParser,
                          Object lastCommit)
                   throws IOException

Specified by:

connect in interface FirehoseFactoryV2<ByteBufferInputRowParser>

Throws:

IOException