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
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