Hi, Can you please little detail stack trace from your receiver logs and also the consumer settings you used ? I have never tested the consumer with Kafka 0.7.3 ..not sure if Kafka Version is the issue . Have you tried building the consumer using Kafka 0.7.3 ?
Regards, Dibyendu On Wed, Jun 10, 2015 at 11:52 AM, karma243 <ashut...@reducedata.com> wrote: > Thank you for responding @nsalian. > > 1. I am trying to replicate this > <https://github.com/dibbhatt/kafka-spark-consumer> project on my local > system. > > 2. Yes, kafka and brokers on the same host. > > 3. I am working with kafka 0.7.3 and spark 1.3.1. Kafka 0.7.3 does not has > "--describe" command. Though I've worked on three cases (Kafka and > Zookeeper > were on my machine all the time): > (i) Producer-Consumer on my machine. > (ii) Producer on my machine and Consumer on different machine. > (iii) Consumer on my machine and producer on different machine. > > All the three cases were working properly. > > > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Kafka-Spark-Streaming-ERROR-EndpointWriter-dropping-message-tp23228p23240.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >
