RE: Spark-Kafka Connector issue

2015-09-28 Thread Ratika Prasad
ommit.enabled=true From: Cody Koeninger [mailto:c...@koeninger.org] Sent: Monday, September 28, 2015 7:56 PM To: Ratika Prasad Cc: dev@spark.apache.org Subject: Re: Spark-Kafka Connector issue This is a user list question not a dev list question. Looks like your driver is having trouble communic

Re: Spark-Kafka Connector issue

2015-09-28 Thread Cody Koeninger
This is a user list question not a dev list question. Looks like your driver is having trouble communicating to the kafka brokers. Make sure the broker host and port is available from the driver host (using nc or telnet); make sure that you're providing the _broker_ host and port to createDirectS

Spark-Kafka Connector issue

2015-09-26 Thread Ratika Prasad
Hi All, I am trying out the spark streaming and reading the messages from kafka topics which later would be created into streams as below...I have the kafka setup on a vm and topics created however when I try to run the program below from my spark vm as below I get an error even though the kafk