Package org.apache.spark.streaming.kafka

Kafka receiver for spark streaming.

See: Description

Class Summary

Class	Description
KafkaInputDStream<K,V,U extends kafka.serializer.Decoder<?>,T extends kafka.serializer.Decoder<?>>	Input stream that pulls messages from a Kafka Broker.
KafkaReceiver<K,V,U extends kafka.serializer.Decoder<?>,T extends kafka.serializer.Decoder<?>>
KafkaUtils
ReliableKafkaReceiver<K,V,U extends kafka.serializer.Decoder<?>,T extends kafka.serializer.Decoder<?>>	ReliableKafkaReceiver offers the ability to reliably store data into BlockManager without loss.

Package org.apache.spark.streaming.kafka Description

Kafka receiver for spark streaming.