Eclipse flags error on KafkaUtils.createStream()

2015-01-08 Thread kc66
Hi, I am using Eclipse writing Java code. I am trying to create a Kafka receiver by: JavaPairReceiverInputDStreamString, kafka.message.Message a = KafkaUtils.createStream(jssc, String.class, Message.class, StringDecoder.class, DefaultDecoder.class, kafkaParams,

Eclipse flags error on KafkaUtils.createStream()

2015-01-07 Thread Kah-Chan Low
Hi,I am using Eclipse writing Java code. I am trying to create a Kafka receiver by: JavaPairReceiverInputDStreamString, kafka.message.Message a  = KafkaUtils.createStream(jssc, String.class, Message.class,     StringDecoder.class, DefaultDecoder.class, kafkaParams,