io.druid.indexing.kafka

Class KafkaIOConfig

java.lang.Object

io.druid.indexing.kafka.KafkaIOConfig

All Implemented Interfaces:

IOConfig

public class KafkaIOConfig
extends Object
implements IOConfig

Constructor Summary

Constructors

Constructor and Description
KafkaIOConfig(String baseSequenceName, KafkaPartitions startPartitions, KafkaPartitions endPartitions, Map<String,String> consumerProperties, Boolean useTransaction, Boolean pauseAfterRead, org.joda.time.DateTime minimumMessageTime)

Method Summary

Modifier and Type	Method and Description
String	getBaseSequenceName()
Map<String,String>	getConsumerProperties()
KafkaPartitions	getEndPartitions()
com.google.common.base.Optional<org.joda.time.DateTime>	getMinimumMessageTime()
KafkaPartitions	getStartPartitions()
boolean	isPauseAfterRead()
boolean	isUseTransaction()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaIOConfig

public KafkaIOConfig(String baseSequenceName,
                     KafkaPartitions startPartitions,
                     KafkaPartitions endPartitions,
                     Map<String,String> consumerProperties,
                     Boolean useTransaction,
                     Boolean pauseAfterRead,
                     org.joda.time.DateTime minimumMessageTime)

Method Detail

getBaseSequenceName

public String getBaseSequenceName()

getStartPartitions

public KafkaPartitions getStartPartitions()

getEndPartitions

public KafkaPartitions getEndPartitions()

getConsumerProperties

public Map<String,String> getConsumerProperties()

isUseTransaction

public boolean isUseTransaction()

isPauseAfterRead

public boolean isPauseAfterRead()

getMinimumMessageTime

public com.google.common.base.Optional<org.joda.time.DateTime> getMinimumMessageTime()

toString

public String toString()

Overrides:

toString in class Object