Kafka-based Job Queue for Python

High performance Kafka consumer for InfluxDB. Supports collectd message formats.

A Python RESTful API using FastAPI with a Kafka Consumer

Data Engineering Project with Hadoop HDFS and Kafka

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.

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

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

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.

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

PyTorch Dataset for Kafka.

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

An naive anomaly detection and data visualization tool for F1 on board telemetry data.

Monitor Kafka Consumer groups (consumers and lag) in Zabbix

Generative AI & Recommendation Engine --- Firat University / Faculty of Technology / Software Engineering / Final Project

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

Python Kafka Messaging