Re: Kafka Spark Streaming: ERROR EndpointWriter: dropping message

2015-06-09 Thread karma243
Thank you for responding @nsalian. 1. I am trying to replicate this 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. Thou

Kafka Spark Streaming: ERROR EndpointWriter: dropping message

2015-06-09 Thread karma243
Hello, While trying to link kafka to spark, I'm not able to get data from kafka. This is the error that I'm getting from spark logs: ERROR EndpointWriter: dropping message [class akka.actor.ActorSelectionMessage] for non-local recipient [Actor[akka.tcp://sparkMaster@localhost:7077/]] arriving at