org.apache.spark.streaming.kafka

v09

package v09

Visibility
  1. Public
  2. All

Type Members

  1. final class Broker extends Serializable

    Represents the host and port info for a Kafka broker.

  2. trait HasOffsetRanges extends AnyRef

    Represents any object that has a collection of OffsetRanges.

  3. final class OffsetRange extends Serializable

    Represents a range of offsets from a single Kafka TopicAndPartition.

Value Members

  1. object Broker extends Serializable

    :: Experimental :: Companion object that provides methods to create instances of Broker.

  2. object KafkaUtils

  3. object OffsetRange extends Serializable

    Companion object the provides methods to create instances of OffsetRange.

Ungrouped