回复：Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread luohui20001
() } } Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：Saisai Shao sai.sai.s...@gmail.com 收件人：luohui20...@sina.com 抄送人：user user@spark.apache.org 主题：Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 14点03分 Hi Hui, Did you try the direct Kafka stream example under Spark Streaming's

Re: Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread Saisai Shao
() } } Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：Saisai Shao sai.sai.s...@gmail.com 收件人：luohui20...@sina.com 抄送人：user user@spark.apache.org 主题：Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 14点03分 Hi Hui, Did you

Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread Akhil Das
Are you having enough messages in kafka to consume? Can you make sure you kafka setup is working with your console consumer? Also try this example https://github.com/apache/spark/blob/master/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala Thanks

Re: Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread Saisai Shao
() } } Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：Saisai Shao sai.sai.s...@gmail.com 收件人：luohui20...@sina.com 抄送人：user user@spark.apache.org 主题：Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 14点03分 Hi Hui, Did you try the direct Kafka

Re: 回复：Re: Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread Saisai Shao
? Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：luohui20...@sina.com 收件人：Saisai Shao sai.sai.s...@gmail.com 抄送人：user user@spark.apache.org 主题：回复：Re: Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 16点46分 Hi Saisai, following your advice, i

回复：回复：Re: Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread luohui20001
? Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：luohui20...@sina.com 收件人：Saisai Shao sai.sai.s...@gmail.com 抄送人：user user@spark.apache.org 主题：回复：Re: Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 16点46分 Hi Saisai, following your advice, i

回复：Re: 回复：Re: Re: How SparkStreaming output messages to Kafka?

2015-03-30 Thread luohui20001
got it.Thank you Thanksamp;Best regards! 罗辉 San.Luo - 原始邮件 - 发件人：Saisai Shao sai.sai.s...@gmail.com 收件人：罗辉 luohui20...@sina.com 抄送人：user user@spark.apache.org 主题：Re: 回复：Re: Re: How SparkStreaming output messages to Kafka? 日期：2015年03月30日 17点05分

转发：How SparkStreaming output messages to Kafka?

2015-03-29 Thread luohui20001
Hi guys, I am using SparkStreaming to receive message from kafka,process it and then send back to kafka. however ,kafka consumer can not receive any messages. Any one share ideas? here is my code: object SparkStreamingSampleDirectApproach { def main(args: Array[String]): Unit =