Kafka + Spark 1.3 Integration

[Nipun Arora]

Hi,

I am trying some basic integration and was going through the manual.

I would like to read from a topic, and get a JavaReceiverInputDStream
<String> for messages in that topic. However the example is of
JavaPairReceiverInputDStream<>. How do I get a stream for only a single
topic in Java?

Reference Page:
https://spark.apache.org/docs/1.3.0/streaming-kafka-integration.html

 import org.apache.spark.streaming.kafka.*;

 JavaPairReceiverInputDStream<String, String> kafkaStream =
     KafkaUtils.createStream(streamingContext,
     [ZK quorum], [consumer group id], [per-topic number of Kafka
partitions to consume]);


Also in the example above what does <String,String> signify?

Thanks
Nipun