You should take a look at https://issues.apache.org/jira/browse/SPARK-4122
which is implementing writing to kafka in a pretty similar way (make a new producer inside foreachPartition) On Mon, Jan 12, 2015 at 5:24 AM, Sean Owen <so...@cloudera.com> wrote: > Leader-not-found suggests a problem with zookeeper config. It depends > a lot on the specifics of your error. But this is really a Kafka > question, better for the Kafka list. > > On Mon, Jan 12, 2015 at 11:10 AM, Hafiz Mujadid > <hafizmujadi...@gmail.com> wrote: > > Actually this code is producing error leader not found exception. I am > > unable to find the reason > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >
