Integrating Kafka 0.10 or higher with Spark 2.1.1 -- required jars

2017-07-07 Thread mahendra singh meena
Hi, After finding that support for streaming api in python is not present for kafka brokers version > 0.10 . I was trying to run a kafka example in scala. I used following spark submit command : /usr/local/spark/bin/spark-submit --jars /home/mahendra/spark- > streaming-kafka-0-10_2.11-2.1.1.ja

Integrating Kafka 0.10 or higher with Spark 2.1.1 -- required jars

2017-07-07 Thread mahendra singh meena
Hi, After finding that support for streaming api in python is not present for kafka brokers version > 0.10 . I was trying to run a kafka example in scala. I used following spark submit command : /usr/local/spark/bin/spark-submit --jars > /home/mahendra/spark-streaming-kafka-0-10_2.11-2.1.1.jar