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, org.joda.time.DateTime maximumMessageTime, Boolean skipOffsetGaps)

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>	getMaximumMessageTime()
com.google.common.base.Optional<org.joda.time.DateTime>	getMinimumMessageTime()
KafkaPartitions	getStartPartitions()
boolean	isPauseAfterRead()
boolean	isSkipOffsetGaps()
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,
                     org.joda.time.DateTime maximumMessageTime,
                     Boolean skipOffsetGaps)

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()

getMaximumMessageTime

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

getMinimumMessageTime

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

isSkipOffsetGaps

public boolean isSkipOffsetGaps()

toString

public String toString()

Overrides:

toString in class Object