Python Stream Processing
-
Updated
Jul 27, 2024 - Python
#
kafka-streams
Here are 126 public repositories matching this topic...
A Python implementation of Apache Kafka Streams
-
Updated
Jan 23, 2019 - Python
Benchmarks for data processing systems: Pathway, Spark, Flink, Kafka Streams
streaming latency pagerank spark-streaming wordcount benchmark-framework flink kafka-streams streaming-data pathway
-
Updated
Dec 29, 2025 - Python
Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.
kafka stream-processing kafka-consumer face-recognition object-detection kafka-producer kafka-streams
-
Updated
Apr 27, 2023 - Python
Explore Apache Kafka data pipelines in Kubernetes.
react python kubernetes data-stream kafka-connect apache-kafka kafka-streams data-pipelines hacktoberfest
-
Updated
Feb 26, 2026 - Python
Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python
python data kafka analytics apache-flink apache-kafka kafka-streams streaming-data spark-structured-streaming kstreams
-
Updated
Dec 28, 2022 - Python
A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.
kafka-topic kafka-consumer kafka-connect faust kafka-producer kafka-streams kafka-schema-registry kafka-cluster kafka-sql kafka-api kafka-application
-
Updated
Aug 14, 2023 - Python
A end-to-end real-time stock market data pipeline with Python, AWS EC2, Apache Kafka, and Cassandra Data is processed on AWS EC2 with Apache Kafka and stored in a local Cassandra database.
python aws real-time kafka cassandra ec2 pipeline etl data-engineering stock-market aws-ec2 ec2-instance apache-kafka kafka-streams kafka-streaming data-pipeline etl-pipeline data-engineering-pipeline stock-market-data-pipeline real-time-data-pipeline
-
Updated
Jun 7, 2023 - Python
Video processing (webcam) in real time using Kafka and Spark.
real-time kafka spark video-processing spark-streaming kafka-consumer kafka-producer video-streaming kafka-streams emotion-recognition
-
Updated
Sep 14, 2020 - Python
AI agent skills for stream processing and event streaming
-
Updated
May 15, 2026 - Python
Implementation of an ETL process for real-time sentiment analysis of tweets with Docker, Apache Kafka, Spark Streaming, MongoDB and Delta Lake
python nlp docker twitter kafka spark mongodb sentiment-analysis etl pyspark spark-streaming kafka-consumer kafka-producer twitter-sentiment-analysis kafka-streams tweet-analysis etl-pipeline delta-lake tweet-classification etl-process
-
Updated
May 6, 2023 - Python
An naive anomaly detection and data visualization tool for F1 on board telemetry data.
kafka spark telemetry spark-streaming kafka-consumer kafka-streams spark-sql anomaly-detection spark-structured-streaming kafka-consumers streamlit streamlit-dashboard streamlit-webapp streamlit-application fastf1
-
Updated
Jun 17, 2022 - Python
Deploy Kafka pipelines to Kubernetes
-
Updated
Apr 9, 2026 - Python
Realtime IoT data streaming from Smartphone sensors
-
Updated
Aug 26, 2020 - Python
Visualize and explore Apache Kafka topologies — topics, producers, consumers, connectors, schemas & ACLs — with an AI assistant that queries live broker metrics via Prometheus
react python kafka ai topology schema-registry devtools prometheus kafka-connect apache-kafka kafka-streams observability data-lineage kafka-ui kafka-monitoring fastapi
-
Updated
Apr 5, 2026 - Python
Use the SSI API to process tick-by-tick stock price data in Vietnam.
python kafka spark websocket stock pyspark kafka-consumer ssi kafka-producer kafka-streams stock-viet-nam
-
Updated
May 6, 2026 - Python
A simple implementation of Kafka message streaming using Python
kafka kafka-consumer kafka-producer kafka-streams python-kafka docker-compose-template kafka-python kafka-consumer-group
-
Updated
Mar 25, 2023 - Python
A scalable architecture for real-time log processing and visualization. Built with a Kafka-Spark ETL pipeline, DynamoDB for storing aggregate real-time metrics, and Python Dash for interactive dashboards. Designed for high-throughput log ingestion, real-time monitoring, and long-term storage.
visualization python docker streaming kafka spark etl docker-compose docker-container dynamodb realtime logs kafka-topic dash spark-streaming kafka-consumer hdfs kafka-producer kafka-streams etl-pipeline
-
Updated
Dec 24, 2024 - Python
Live sentiment analysis of tweets using Kafka
elasticsearch kibana kafka tweets sentiment-analysis twitter-api zookeeper kafka-topic spark-streaming apache-kafka twitter-sentiment-analysis kafka-streams live-tweets vader-sentiment-analysis kibana-visualization big-data-analytics trump-tweets textblob-sentiment-analysis kafka-producer-consumer coronavirus
-
Updated
May 11, 2020 - Python
Improve this page
Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the kafka-streams topic, visit your repo's landing page and select "manage topics."