./venv/lib/python3.9/site-packages/pyspark/bin/spark-submit --master local --packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.3.0 main.py {"key":"12312","event":"user-logged-in", "date": 12345234, "json": "{}"}