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.
-
Notifications
You must be signed in to change notification settings - Fork 0
Transform streaming messages
License
textpipe/streamprocessor
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
Transform streaming messages
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published