kafka

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

Your shiny new IO & Actor programming model!

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

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...

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

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

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

[READ-ONLY] The Kafka Enqueue transport.

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

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

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

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

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

Connect to CloudKarafka using Java and SASL/SCRAM-authentication

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

Message validator for Kafka/RabbitMQ/Anything through AsyncAPI schema

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

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...

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

SNMP Trap to JSON Forwarder

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

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

KafkaPeek is an open-source application designed to help developers visualize, monitor, and stay up-to-date on their Kafka deployments

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

Kotlin Clean Architecture and CQRS microservice

Thin Scala wrapper for the Kafka Streams API

The extension adds messaging capabilities to Magento2 application.

A Spring Boot Camel boilerplate that aims to consume events from Apache Kafka, process it and send to a PostgreSQL database.

A Kafka Connect Source for FTP servers - Monitors files on an FTP server and feeds changes into Kafka

DevOps

Spring Kafka with unit test example

Monitor your Kafka clusters in real time

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

Kafka consumer lag monitor

Outbrain's data pipeline framework