Python Stream Processing
-
Updated
Jul 27, 2024 - Python
#
kafka-streams
Here are 100 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
Jan 30, 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 19, 2025 - 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
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
Deploy Kafka pipelines to Kubernetes
-
Updated
Feb 21, 2025 - 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
Realtime IoT data streaming from Smartphone sensors
-
Updated
Aug 26, 2020 - 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 Python starter pack for building streaming applications with Memgraph.
-
Updated
Dec 21, 2021 - 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
A comprehensive data engineering pipeline has been established to coordinate the ingestion, processing, and storage of data. This pipeline utilizes Apache Airflow, Python, Apache Kafka, Apache Zookeeper, Apache Spark, and FastDBs. All these components have been containerized with Docker to facilitate straightforward deployment and scalability
-
Updated
Jan 12, 2024 - Python
A real time stock prices tracker using Kafka
python kafka python3 consumer kafka-consumer kafka-producer producer producer-consumer kafka-streams confluent-kafka kafka-producer-consumer
-
Updated
Sep 9, 2023 - Python
A proof of concept about collecting real-time clickstream data using Javascript, Divolte Collector, Apache Kafka, Kafka Streams, Apache Druid and Apache Superset.
-
Updated
Sep 22, 2021 - 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."