kafka

Streaming data changes to a Data Lake with Debezium and Delta Lake pipeline

Kafka Akka.Streams connectors - part of the Alpakka project

Developed user profile, connections, job listing and application modules using MERN Stack and Kafka. Implemented Redis for data caching, containerized...

Kafka Pub/Sub for the Watermill project.

POC for a financial domain application.

Data Engineering examples for Airflow, Prefect; dbt for BigQuery, Redshift, ClickHouse, Postgres, DuckDB; PySpark for Batch processing; Kafka for Stre...

Simulated production environment running Kubernetes targeting Apache Kafka and Confluent components on Confluent Cloud. Managed by declarative infrast...

Axon Framework extension for Kafka integration to publish and handle Event messages.

System design exercises by Arpit Bhayani

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

Microservices Architecture Workshop focuses on helping the developers / architects to understand the key Architecture paradigms with hands on section....

Use Kafka and Apache Spark streaming to perform click stream analytics

A financial data processing and visualization platform using Apache Kafka, Apache Cassandra, and Bokeh.

Kafka Connect Elasticsearch Source

Golang Clean Architecture Example

An easy-to-use, lightweight KafkaJS library for message re-processing.

Prometheus Kafka Consumer Group Exporter

Final Project for IoT: Big Data Processing and Analytics class. Analyzing U.S nationwide temperature from IoT sensors in real-time

Big Data Management and Analysis Final Project

E-Commerce API Made With NodeJs,Typescript,PostgreSQL,Redis And Kafka

A gem providing cross-platform Kafka producer and consumer support

OCaml bindings for Kafka

Fastify plugin to interact with Apache Kafka

A sample of non-blocking retries and dead letter topics (aka reliable reprocessing and dead letter queues) with Apache Kafka using Spring Boot and Spr...

Prometheus exporter for Kafka cluster state stored in ZooKeeper

Real-time analysis of bitcoin markets with Kafka and Tensorflow Serving

Kryptonite for Kafka is a client-side 🔒 field level 🔓 cryptography library for Apache Kafka® offering a Kafka Connect SMT, ksqlDB UDFs, and a standa...

Aiven's S3 Sink Connector for Apache Kafka®

一个基于 Spring Cloud 的微服务客服系统

Applicant Management at Any Scale. Currently WIP! :D

Телеграм бот на GO (Golang)

Apache Kafka Guide

Playground for Lakehouse (Iceberg, Hudi, Spark, Flink, Trino, DBT, Airflow, Kafka, Debezium CDC)

Kafka client for elixir

Apache Camel Kamelets Repository

Library offering http based query on top of Kafka Streams Interactive Queries

In-deprecation. For Lenses please check lensesio/lenses-helm-charts. Soon Stream Reactor will also get its own Helm repository.

Sync & Manipulate data from MySQL/MongoDB to Elasticsearch/MySQL/Kafka Endpoint

Aiven's GCS Sink Connector for Apache Kafka®

FlinkTutorial 专注大数据Flink流试处理技术。从基础入门、概念、原理、实战、性能调优、源码解析等内容，使用Java开发，同时含有Scala部分核心代码。欢迎关注我...

A Golang client for ksqlDB

An efficient and scalable library for stateless Kafka message processing written in Go

Source backend for website/mobile about electro, e-commerce using Java, using multi-language (EN, VI), and today's popular technologies

The goal of this project is to implement two Spring Boot applications: bitcoin-api and bitcoin-client. The bitcoin-api application simulates BTC price...

Apache Kafka on Kubernetes

Code and presentation for Strata Model Serving tutorial

Dermayon is Library for supporting build large application,distributed application, scalable, microservices, cqrs, event sourcing, including generic e...

SpringBoot 整合各类框架和应用