Install librdkafka:
brew install librdkafka
$ echo '{"test": 1, "a": 3, "c": 4}' | python example.py keys
PYSPARK_PYTHON=python spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_2.11:2.3.0 --py-files streamprocessor/ example_spark.py
This repository was archived by the owner on Nov 23, 2021. It is now read-only.
textpipe/streamprocessor
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|