Parses raw trades data from Kafka topics to a better message format

Generate bash scripts and properties for Confluent Platform.

apache kafka and python api sample usages

Sample Python producer and consumer based on the Confluent Developer Apache Kafka 101 course

HackDavis 2021 Project. First Prize in Best use of Confluent Platforms.

Construct a streaming event pipeline around Apache Kafka and its ecosystem. Using public data from the Chicago Transit Authority, we will construct an event pipeline around Kafka that allows us to simulate and display the status of train lines in real time.

Confluent Kafka RPM based docker images

Docker kafka confluent

Python Wrapper to Confluent CLI

Simple local running Apache Kafka implementation using confluent-kafka

Real time data streaming in containerized manner using Docker, Apache Airflow, Apache Kafka on Confluent network, consumed from API after performing data transformations.

Multi broker confluent deployment using ansible.

100 Days of Code with Apache Kafka

Using OpenSky API to track flights in real-time. Kafka + MemSQL/BigQuery

Real-time data ingestion to Cassandra using Airflow, Kafka, and Spark.

Interactive ksqlDB command line client with autocompletion and syntax highlighting written in Python

Terraform template for Confluent Platform POC on AWS

Convert AVRO events to JSON and perform schema validation using EventBridge Pipes and Confluent Schema Registry.

End-to-end Kafka ecosystem lab: streaming, monitoring, connectors, security and more.

Python library for practicing the event sourcing pattern using DDD