kafka

k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond

Oracle database CDC (Change Data Capture)

This is a NodeJS/Angular 2 frontend UI for Kafka cluster monitoring with Burrow

CLI for Apache Kafka Management -

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

Minimal F# wrappers for Confluent.Kafka+librdkafka.redist 1.x

Kafka Connector for Zeebe.io

The source code of the book "Spring Microservices in Action (John Carnell)" and the personal summary of technical essentials about Spring Boot for mic...

A micro-service infrastructure generator based on Yeoman/Chatbot, Kubernetes/Docker Swarm, Traefik, Ansible, Jenkins, Spark, Hadoop, Kafka, etc.

Kafka integration for Kubernetes

Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example

Management and automation platform for Stateful Distributed Systems

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice appl...

Kafka client for functional streams for scala (fs2)

Docker - ELK - Tick Stack - Grafana - Kafka

A fast and lightweight Redis Proxy and Kafka Proxy

Solana geyser plugin implementing a Kafka publisher

📺 Netflix in Rust/ React-TS/ NextJS, Actix-Web, Async Apollo-GraphQl, Cassandra/ ScyllaDB, Async SQLx, Kafka, Redis, Tokio, Actix, Elasticsearch, Inf...

Event sourcing with kafka and nodejs

单节点的一个kafka容器环境，包括zookeeper、kafka、kafka eagle

The developer-friendly ETL platform for transforming data in real-time. Based on Apache Kafka® and Kubernetes®.

🚨 Simple, self-contained fraud detection system built with Apache Kafka and Python

Herman基于Gin，Casbin，Kafka，Mysql，Redis，Zap，Cobra，Grom开发，专注于后端快速上手的一款开源，简单，轻量框架。

Kafka-based components for Scrapy

最好的大数据项目。《Titan数据运营系统》，本项目是一个全栈闭环系统，我们有用作数据可视化的web系统，然后用flume-kafaka-flume进行日志的读取，在hive设计数...

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

Rapid Avro serializer for C# .NET

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

Use Kafka and Apache Spark streaming to perform click stream analytics

🚀 Stream inferences of real-time ML models in production to any data lake (Experimental)

Erlang kafka driver based on librdkafka

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

Integration between Micronaut and Apache Kafka

This project walks through how you can create recommendations using Apache Spark machine learning. There are a number of jupyter notebooks that you ca...

Machine learning around business processes

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

Prometheus Kafka Consumer Group Exporter

An open source kafka monitoring and management tool built with Javascript developers in mind!

RabbitMQ to Kafka bridge

Prometheus exporter for Kafka cluster state stored in ZooKeeper

Apache Kafka on Kubernetes

Code and presentation for Strata Model Serving tutorial

A gem providing cross-platform Kafka producer and consumer support

Open Source ETL designed for and dedicated to Log processing and transformation

Mercury - reference engine for composable application

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

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

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

Ship changes in Postgres 🐘 to Kafka 📖