Re: Error reading from Kafka

Hi Saisai, thanks you for your help, all is working ok now. Cheers! 2014-10-09 2:49 GMT+02:00 Shao, Saisai saisai.s...@intel.com: Hi, I think you have to change the code like this to specify the type info, like this: * val kafkaStream: ReceiverInputDStream[(String, String)] =

RE: Error reading from Kafka

Hi, I think you have to change the code like this to specify the type info, like this: val kafkaStream: ReceiverInputDStream[(String, String)] = KafkaUtils.createStream[String, String, StringDecoder, StringDecoder]( ssc, kafkaParams, topicMap,