kafka

CMAK (prev. Kafka Manager) for Kubernetes

Kafka Connect connectors for Azure Cosmos DB

Java体系架构知识点整理，包括Java基础、Spring、MySQL、算法题等

An open-source GUI for managing and monitoring Kafka cluster health

The Internals of Apache Kafka

A simple Python-based distributed workflow engine

Kafka GUI Client

Spring boot cloud microservices practical example series with latest technologies

Cloud native chaos engineering toolkit for Go. Inject faults across HTTP, gRPC, Kafka, Redis, SQL, and MongoDB. YAML defined policies, multi model Ora...

Columbia Image and Face Search tool for MEMEX

Karafka and WaterDrop example applications

Java相关框架, java 基础, Spring, mybsatis ,SpringBoot ,分布式,微服务

A Kafka source connector capturing Scylla CDC changes

KafScale delivers Kafka-compatible data streaming on S3. Scale infinitely, stateless brokers and processors.

Knowledge base for python backend developers

基础框架

Kalium: a reactive framework for micro-services

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

Java implementation of the Moleculer microservices framework

Enables you to start and stop a fully-fledged embedded Kafka cluster from within JUnit and provides a rich set of convenient accessors and fault injec...

Data pipeline project

AsyncAPI Event Gateway

Docker Compose environments for developing modern data platform architectures using Kafka, Flink, Spark, Iceberg, OpenLineage, OpenMetadata, Pinot, Cl...

A DuckDB Extension for Kafka

Repository containing Cloud Storage Connectors for Apache Kafka®

Your API mocking tool for OpenAPI and AsyncAPI using Go and JavaScript - https://mokapi.io

Composable Kafka consumer library for building modular, testable JVM data pipelines.

Flume NG Canal source

A client UI to inspect Kafka topics, consume, produce and much more

Monitoring & tech stack for developers

cqrs是基于事件回溯的高性能架构，主要针对单个领域业务高度复杂且需要高性能的业务场景，可以说它能够作为高并发系统的通用解决方案。例如：秒杀、抢红包、1230...

AI agent skills for building, operating and troubleshooting Apache Kafka applications. Topic audit, consumer lag, schema review, security, connectors...

Kafka proxy with a simple API, speaking the Redis protocol

Yet another Web UI for KSQL

A library provides consumer/producer to work with kafka, avro and schema registry

Client tool that exports the consumer lag of Kafka consumer groups to Prometheus or your terminal

kdb+ to Apache Kafka adapter, for pub/sub

This repository contains the code base for the Open Stream Processing Benchmark.

Kafka Connect connector that reads JSON data from Apache Kafka and send JSON record to Another Kafka topic.

Kafka Connect Source connector for Wikimedia EventStreams

Kafka Connect connector for JDBC-compatible databases

💥 A simple multi-purpose connection pool client (Kafka & Hbase & Redis & RMDB & Socket & Http)

A Kafka Connect sink plugin to invoke AWS Lambda functions

Sentiment Analysis of a Twitter Topic with Spark Structured Streaming

An avro converter for Kafka Connect without a Schema Registry

SWIR - Sidecar Written In Rust

App Server independent JCA Connectors for Jakarta EE that connect to Cloud Services.

A Zeek log writer plugin that publishes to Kafka.

Want to work with us? Here is a mini-coding challenge you can try :)

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin