kafka

Type Members

1. final class Broker extends Serializable

   

   Represents the host and port info for a Kafka broker.

   Represents the host and port info for a Kafka broker. Differs from the Kafka project's internal kafka.cluster.Broker, which contains a server ID.

2. trait HasOffsetRanges extends AnyRef

   

   Represents any object that has a collection of OffsetRanges.

   Represents any object that has a collection of OffsetRanges. This can be used to access the offset ranges in RDDs generated by the direct Kafka DStream (see KafkaUtils.createDirectStream()).

   KafkaUtils.createDirectStream(...).foreachRDD { rdd =>
      val offsetRanges = rdd.asInstanceOf[HasOffsetRanges].offsetRanges
      ...
   }

3. class KafkaCluster extends Serializable

   

   :: DeveloperApi :: Convenience methods for interacting with a Kafka cluster.

   :: DeveloperApi :: Convenience methods for interacting with a Kafka cluster. See A Guide To The Kafka Protocol for more details on individual api calls.

   Annotations

   @DeveloperApi()

4. final class OffsetRange extends Serializable

   

   Represents a range of offsets from a single Kafka TopicAndPartition.

   Represents a range of offsets from a single Kafka TopicAndPartition. Instances of this class can be created with OffsetRange.create().