org.apache.spark.streaming.kafka
Interfaces
HasOffsetRanges
Classes
Broker
KafkaCluster
KafkaCluster.LeaderOffset
KafkaCluster.LeaderOffset$
KafkaCluster.SimpleConsumerConfig
KafkaCluster.SimpleConsumerConfig$
KafkaUtils
OffsetRange