io.druid.indexing.kafka.supervisor

Class KafkaSupervisorIOConfig

java.lang.Object

io.druid.indexing.kafka.supervisor.KafkaSupervisorIOConfig

public class KafkaSupervisorIOConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOOTSTRAP_SERVERS_KEY

Constructor Summary

Constructors

Constructor and Description
KafkaSupervisorIOConfig(String topic, Integer replicas, Integer taskCount, org.joda.time.Period taskDuration, Map<String,String> consumerProperties, org.joda.time.Period startDelay, org.joda.time.Period period, Boolean useEarliestOffset, org.joda.time.Period completionTimeout, org.joda.time.Period lateMessageRejectionPeriod)

Method Summary

Modifier and Type	Method and Description
org.joda.time.Duration	getCompletionTimeout()
Map<String,String>	getConsumerProperties()
com.google.common.base.Optional<org.joda.time.Duration>	getLateMessageRejectionPeriod()
org.joda.time.Duration	getPeriod()
Integer	getReplicas()
org.joda.time.Duration	getStartDelay()
Integer	getTaskCount()
org.joda.time.Duration	getTaskDuration()
String	getTopic()
Boolean	isUseEarliestOffset()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAP_SERVERS_KEY

public static final String BOOTSTRAP_SERVERS_KEY

See Also:

Constant Field Values

Constructor Detail

KafkaSupervisorIOConfig

public KafkaSupervisorIOConfig(String topic,
                               Integer replicas,
                               Integer taskCount,
                               org.joda.time.Period taskDuration,
                               Map<String,String> consumerProperties,
                               org.joda.time.Period startDelay,
                               org.joda.time.Period period,
                               Boolean useEarliestOffset,
                               org.joda.time.Period completionTimeout,
                               org.joda.time.Period lateMessageRejectionPeriod)

Method Detail

getTopic

public String getTopic()

getReplicas

public Integer getReplicas()

getTaskCount

public Integer getTaskCount()

getTaskDuration

public org.joda.time.Duration getTaskDuration()

getConsumerProperties

public Map<String,String> getConsumerProperties()

getStartDelay

public org.joda.time.Duration getStartDelay()

getPeriod

public org.joda.time.Duration getPeriod()

isUseEarliestOffset

public Boolean isUseEarliestOffset()

getCompletionTimeout

public org.joda.time.Duration getCompletionTimeout()

getLateMessageRejectionPeriod

public com.google.common.base.Optional<org.joda.time.Duration> getLateMessageRejectionPeriod()

toString

public String toString()

Overrides:

toString in class Object