Dear spark dev
I am trying to run IPython notebook with Kafka structured streaming
support, I couldn't find a way to load Kafka package by adding "--packages
org.apache.spark:spark-sql-kafka-0-10_2.11:2.4.0"
to PYSPARK_DRIVER_PYTHON_OPTS or even I changed my local pyspark script to
"exec "${SPARK_HOME}"/bin/spark-submit --packages
org.apache.spark:spark-sql-kafka-0-10_2.11:2.4.0 pyspark-shell-main --name
"PySparkShell" "$@"". Could anyone here point out  the correct way to add
support for Kafka streaming for python notebook.

Much appreciated.

Haibo

Reply via email to