Hi All, I would like to use PySpark Streaming with secured Kafka as the source stream.
What options or arguments that I should pass in spark-submit command? A sample spark-submit command with all the required options/arguments to access a remote-secured Kafka will help. Thank you, ~Muthu R