Uses of Class
io.druid.indexing.kafka.KafkaPartitions

Packages that use KafkaPartitions

Package	Description
io.druid.indexing.kafka

Uses of KafkaPartitions in io.druid.indexing.kafka

Methods in io.druid.indexing.kafka that return KafkaPartitions

Modifier and Type	Method and Description
KafkaPartitions	KafkaIOConfig.getEndPartitions()
KafkaPartitions	KafkaDataSourceMetadata.getKafkaPartitions()
KafkaPartitions	KafkaIOConfig.getStartPartitions()

Constructors in io.druid.indexing.kafka with parameters of type KafkaPartitions

Constructor and Description
KafkaDataSourceMetadata(KafkaPartitions kafkaPartitions)
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)