public class KafkaEightFirehoseFactory extends Object implements io.druid.data.input.FirehoseFactory<io.druid.data.input.ByteBufferInputRowParser>
Constructor and Description |
---|
KafkaEightFirehoseFactory(Properties consumerProps,
String feed) |
Modifier and Type | Method and Description |
---|---|
io.druid.data.input.Firehose |
connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser) |
public KafkaEightFirehoseFactory(Properties consumerProps, String feed)
public io.druid.data.input.Firehose connect(io.druid.data.input.ByteBufferInputRowParser firehoseParser) throws IOException
connect
in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.ByteBufferInputRowParser>
IOException
Copyright © 2011–2016. All rights reserved.