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.
|