RE: Setting Kafka parameters in Spark Streaming

2014-09-08 Thread Shao, Saisai
, September 09, 2014 1:19 PM To: Shao, Saisai Cc: user@spark.apache.org Subject: Re: Setting Kafka parameters in Spark Streaming Thanks, Shao, for providing the necessary information. Hemanth On Tue, Sep 9, 2014 at 8:21 AM, Shao, Saisai mailto:saisai.s...@intel.com>> wrote: Hi Hemanth, I

Re: Setting Kafka parameters in Spark Streaming

2014-09-08 Thread Hemanth Yamijala
Thanks, Shao, for providing the necessary information. Hemanth On Tue, Sep 9, 2014 at 8:21 AM, Shao, Saisai wrote: > Hi Hemanth, > > > > I think there is a bug in this API in Spark 0.8.1, so you will meet this > exception when using Java code with this API, this bug is fixed in latest > versio

RE: Setting Kafka parameters in Spark Streaming

2014-09-08 Thread Shao, Saisai
Hi Hemanth, I think there is a bug in this API in Spark 0.8.1, so you will meet this exception when using Java code with this API, this bug is fixed in latest version, as you can see the patch (https://github.com/apache/spark/pull/1508). But it’s only for Kafka 0.8+, as you still use kafka 0.7,