Kafka Streaming Application PySpark application to read taxi rides from Kafka topics, union them and analyse Link to the Kafka producer implementation: kafka-taxi-rides-producer