Package org.apache.spark.streaming.kafka

Kafka receiver for spark streaming.

See: Description

Interface Summary

Interface	Description
HasOffsetRanges	:: Experimental :: Represents any object that has a collection of OffsetRanges.

Class Summary

Class	Description
Broker	:: Experimental :: Represent the host and port info for a Kafka broker.
KafkaTestUtils	This is a helper class for Kafka test suites.
KafkaUtils
KafkaUtilsPythonHelper	This is a helper class that wraps the KafkaUtils.createStream() into more Python-friendly class and function so that it can be easily instantiated and called from Python's KafkaUtils (see SPARK-6027).
OffsetRange	:: Experimental :: Represents a range of offsets from a single Kafka TopicAndPartition.

Package org.apache.spark.streaming.kafka Description

Kafka receiver for spark streaming.