, 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
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
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,