Kafka-based Job Queue for Python

The Python fake data producer for Apache Kafka® is a complete demo app allowing you to quickly produce JSON fake streaming datasets and push it to an Apache Kafka topic.

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.

Distributed Streaming with Apache Kafka and Python OpenCV

A Saga Pattern implementation with Kafka, MongoDb and Python.

An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka

A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.

Video processing (webcam) in real time using Kafka and Spark.

Kafka PoC using FastAPI

A structured streaming was applied to the robot data from ROS-Gazebo simulation environment using Apache Spark. Data is collected in Kafka, analyzed by Apache Spark and stored in Cassandra.

Efficient Pandas and Ray Kafka Producer for python using actor model.

Python script demonstrating spark streaming and Kafka implementation using an e-commerce website like product recommendation engine based on item-based collaborative filtering. 🐍. 💥

Implementation of an ETL process for real-time sentiment analysis of tweets with Docker, Apache Kafka, Spark Streaming, MongoDB and Delta Lake

The Apache Kafka Connector connects to the IE Databus and Apache Kafka.

Python Kafka Messaging

A Kafka python library for Robotframework to test events(messages) in Kafka.

✔️ Twitter Realtime Processing about Covid-19 + Docker + Docker Compose + Apache Kafka + Elastic Stack (Elasticsearch + Kibana)

Data Engineering Project with Hadoop HDFS and Kafka

Detection of DDOS Attack using Kafka and Spark Streaming

A simple implementation of Kafka message streaming using Python