Python Kafka reset consumergroup offset example
A simple example of how to reset consumergroup offset for a given topic without creating new unique consumergroup names
Unified API of Apache Kafka and Google PubSub
Unified API of Apache Kafka and Google PubSub
A simple healthcheck wrapper to monitor Kafka
A simple healthcheck wrapper to monitor Kafka
Project demonstrating the use of Elasticsearch with Kafka
Project demonstrating the use of Elasticsearch with Kafka
PythonKafkaCompose is an upgrade of the amazing work done in liveMaps
PythonKafkaCompose is an upgrade of the amazing work done in liveMaps
Fetching tweets and integrating it with Kafka and PySpark
Fetching tweets and integrating it with Kafka and PySpark
A real-time financial data streaming pipeline and visualization platform using Apache Kafka, Cassandra, and Bokeh
A real-time financial data streaming pipeline and visualization platform using Apache Kafka, Cassandra, and Bokeh
A real-time financial data streaming pipeline and visualization platform using Apache Kafka, Cassandra, and Bokeh
A real-time financial data streaming pipeline and visualization platform using Apache Kafka, Cassandra, and Bokeh
Reading streams of Twitter data, save them to Kafka, then process with Kafka Stream API and Spark Streaming
Reading streams of Twitter data, save them to Kafka, then process with Kafka Stream API and Spark Streaming
Confluent's Kafka Python Client
Confluent's Kafka Python Client
Microservice example with Python, Faust-Streaming and Kafka (Redpanda)
Microservice example with Python, Faust-Streaming and Kafka (Redpanda)
Mock stream producer for time series data using Kafka
Fully reproducible, Dockerized, step-by-step, tutorial on how to mock a "real-time" Kafka data stream from a timestamped csv file. Detailed blog post
Project for real time anomaly detection using kafka and python
Project for real time anomaly detection using kafka and python.