public class KafkaEightSimpleConsumerFirehoseFactory extends Object implements io.druid.data.input.FirehoseFactoryV2<io.druid.data.input.ByteBufferInputRowParser>
Constructor and Description |
---|
KafkaEightSimpleConsumerFirehoseFactory(List<String> brokerList,
List<Integer> partitionIdList,
String clientId,
String feed,
Integer queueBufferLength,
Boolean resetOffsetToEarliest) |
Modifier and Type | Method and Description |
---|---|
io.druid.data.input.FirehoseV2 |
connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser,
Object lastCommit) |
public io.druid.data.input.FirehoseV2 connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser, Object lastCommit) throws IOException
connect
in interface io.druid.data.input.FirehoseFactoryV2<io.druid.data.input.ByteBufferInputRowParser>
IOException
Copyright © 2011–2016. All rights reserved.