kafka

Kiwi powers extensible, real-time data streaming to your end users

Kafka Connect Source connector for Wikimedia EventStreams

Your shiny new IO & Actor programming model!

A data and analytics engineering platform designed for real-time sports betting analytics.

A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.

100+ data engineering projects from scratch — streaming, CDC, table formats, query engines, consensus, governance. 2,500+ tests, mypy strict.

💥 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

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

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

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

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

ansible playbook to deploy cloudera hadoop components to the cluster

:baseball: Streaming left joins in Kafka for change data capture

How to build your first Spark application with MLlib, StructuredStreaming, GraphFrames, Datasets and so on? Answer is here!

Kafka End to End Encryption

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernet...

[READ-ONLY] The Kafka Enqueue transport.

A replica of online travel booking site KAYAK(www.kayak.com) for cmpe-273. Visit ->

An Apache Kafka cluster size calculator

C++ Kafka coroutine library using Quantum dispatcher and wrapping CppKafka

Feature demos, integration guides & hands-on labs/projects using Kpow, Flex, Kafka, Flink, Iceberg & more

Event-Driven Tutorial for Distributed Data with CQRS and Event Sourcing

CLI tool and Go client library for the Kafka Connect REST API

Docker image for Kafka (0.10.x - 0.11.x - 1.x, 2.x) message broker including Zookeeper

使用Docker与Docker-compose快速搭建的一些中间件和软件环境，包括Redis哨兵、RocketMq、RabbitMq、Kafka、Mysql主从等等

Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.

Repository with configuration for Terraform and Argo CD to create and manage Kubernetes cluster locally with Kind

.NET Suite for Apache Kafka™: full Apache Kafka™ API access from .NET — Producer, Consumer, Admin, Streams, Connect, KRaft. Compatible with any Kafka™...

Source code repository for the 2nd Edition of Kafka Streams in Action

SNMP Trap to JSON Forwarder

Kotlin Clean Architecture and CQRS microservice

Connect to CloudKarafka using Java and SASL/SCRAM-authentication

Java 工程师必备的技术知识点，全力打造Java 程序员的技能体系知识库；主要体现在 Java 基础、算法、网络、后端框架、数据库、操作系统等方面知识整理。对于Java...

Message validator for Kafka/RabbitMQ/Anything through AsyncAPI schema

Inspect messages in a Kafka topic in a simple and deliberate manner

대규모 트래픽 처리가 가능한 실시간 채팅 서비스

Ruby gem for simplified Pact testing between microservices, supporting the latest Pact specifications and multiple transport protocols

Create an executable project (API and Admin App) from a database or natural language prompt with 1 command, customize with declarative rules and Pytho...

Customer Relationship Management helps to manage tasks, assign deadlines, control user roles, use of admin panel, feedback management, sales represent...

Fabric sample with kafka orderer type

Redis Kafka Streams State Store

使用Storm实时处理交通大数据（数据源：kafka，集群管理：zookeeper）

大数据学习笔记，学习路线，技术案例整理。

📕 Kafka Connect source and sink connector for Redis

Scalable Kubernetes logging stack with Opensearch