Re: Spark Streaming Kafka could not find leader offset for Set()

String.class, >>>>>> String.class, >>>>>> StringDecoder.class, >>>>>> StringDecoder.class, >>>>>> kafkaParams, >>>&

Re: Spark Streaming Kafka could not find leader offset for Set()

(jssc, >>>>> String.class, >>>>> String.class, >>>>> StringDecoder.class, >>>>> StringDecoder.class, >>>>>

Re: Spark Streaming Kafka could not find leader offset for Set()

Decoder.class, >>>> StringDecoder.class, >>>> kafkaParams, >>>> topicSet); >>>> >>>> Kafka param is only one I specify kafka.ofset.reset=largest. Kafka >>>>

Re: Spark Streaming Kafka could not find leader offset for Set()

exception saying leader offset not found. I tried both >>> smallest >>> and largest offset. I wonder what happened this code used to work >>> earlier. I >>> am using Spark-Streaming 1.3.1 as it was working in this version I tried >>> in >>> 1.4.1

Re: Spark Streaming Kafka could not find leader offset for Set()

work >> earlier. I >> am using Spark-Streaming 1.3.1 as it was working in this version I tried >> in >> 1.4.1 and same exception. Please guide. I am new to Spark thanks in >> advance. >> >> >> >> >> -- >> View this message in context: &g

Re: Spark Streaming Kafka could not find leader offset for Set()

exception. Please guide. I am new to Spark thanks in > advance. > > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-Kafka-could-not-find-leader-offset-for-Set-tp24066.html > Sent from the Apache Spark User List m

Spark Streaming Kafka could not find leader offset for Set()

list.1001560.n3.nabble.com/Spark-Streaming-Kafka-could-not-find-leader-offset-for-Set-tp24066.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscribe, e-mail: user-unsubscr...@spark.apache.org