Python Django as Producer and Consumer using Apache Kafka for content queue and Celery for task queue

Project for real-time anomaly detection using Kafka and python

Robot Framework keyword library wrapper for python confluent kafka

Playground for Kafka / Confluent Kubernetes experimentations

This project demonstrates an end-to-end data pipeline, integrating cloud storage, data processing, and real-time visualization. It serves as a practical foundation for similar data engineering and analytics workflows.

This repo contains all materials regarding Udacity's data streaming nanodegree

Terraform template for Confluent Platform POC on AWS

Deploy Apache Kafka using docker-compose

Streaming kafka events using Spark in avro format and saving the events in parquet format

A simple producer in python

A real time stock prices tracker using Kafka

Udacity Data Streaming Nanodegree project

Embedded Kafka for Python - Testing library for confluent_kafka

Pythonic KSQL REST API - Next Gen.

A simple Kafka wrapper based on confluent_kafka python client.

100 Days of Code with Apache Kafka

Real-time Coinbase market data streaming pipeline with visualizations. Much appreciation to DataTalks.Club Data Engineering Zoom Camp: https://github.com/DataTalksClub/data-engineering-zoomcamp

EventMusic Producer is a Dockerized application designed to read data and output them to a Kafka topic, using Avro schemas for data serialization. It integrates seamlessly with Kafka and the Schema Registry to manage the flow of event data linked to music event information.

A microframework designed to provide a simple interface for interacting with Kafka

Search your Kafka topics with this python flask web browser. kafka-topics-message-browser allows for customizable browsing/searching of Kafka topics. Functionality: provide desired string and topics, browser will return all messages within requested topics that contain desired string. Default format parsers provided: json and avro.