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 : > Hi, I think you have to change the code like this to specify the type > info, like this: > > > > * val kafkaStream: ReceiverInputDStream[(String, String)] = > KafkaUtils.createStr

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, StorageLevel.MEMORY_AND_DISK_S