io.druid.firehose.kafka

Class KafkaSimpleConsumer

java.lang.Object

io.druid.firehose.kafka.KafkaSimpleConsumer

public class KafkaSimpleConsumer
extends Object

refer @{link https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example}

This class is not thread safe, the caller must ensure all the methods be called from single thread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaSimpleConsumer.BytesMessageWithOffset

Field Summary

Fields

Modifier and Type	Field and Description
static List<KafkaSimpleConsumer.BytesMessageWithOffset>	EMPTY_MSGS

Constructor Summary

Constructors

Constructor and Description
KafkaSimpleConsumer(String topic, int partitionId, String clientId, List<String> brokers, boolean earliest)

Method Summary

Modifier and Type	Method and Description
Iterable<KafkaSimpleConsumer.BytesMessageWithOffset>	fetch(long offset, int timeoutMs)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_MSGS

public static final List<KafkaSimpleConsumer.BytesMessageWithOffset> EMPTY_MSGS

Constructor Detail

KafkaSimpleConsumer

public KafkaSimpleConsumer(String topic,
                           int partitionId,
                           String clientId,
                           List<String> brokers,
                           boolean earliest)

Method Detail

fetch

public Iterable<KafkaSimpleConsumer.BytesMessageWithOffset> fetch(long offset,
                                                                  int timeoutMs)
                                                           throws InterruptedException

Throws:

InterruptedException

stop

public void stop()