Top 766 kafka open source projects

Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.

CLI and Go Clients to manage Kafka components (Kafka Connect & SchemaRegistry)

☝️Implement all kafka protocols, providing 'HighLevel' and 'LowLevel' client apis respectively, and utilize swoole to realize collaboration and flexibly extend consumers' client, which is the first php-kafka client to support multiple compression forms

Limit simultaneous viewing with Apache Kafka & Spring Boot Microservices, Redis

A command line client of kafka

Kanadi is a Nakadi client for Scala

Cross-vendor normalisation for network syslog messages, following the OpenConfig and IETF YANG models

Kafka Connect Connector for Jenkins Open Source Continuous Integration Tool

Go event sourcing with Kafka, example project

A distributed fake data generator based in Akka.

Serializer/Deserializer for Kafka to serialize/deserialize Protocol Buffers messages

Scalable Kubernetes logging stack with Opensearch

Collection of Databricks and Jupyter Notebooks

Redis Kafka Streams State Store

A Kafka Cookbook for Chef

Distributed Message Queue based on Raft

A Mysql data to file/elasticsearch/kafka/redis/redis-cluster/mongodb(audit and normal)/TiDB/postgresql with binlog tool.

PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka

gosquito ("go" + "mosquito") is a pluggable tool for data gathering, data processing and data transmitting to various destinations.

An Apache Kafka cluster size calculator

Rust Kafka HTTP proxy

Felice is a nascent, opinionated Kafka library for Go, in Go

Distributed task redisqueue(最简单python分布式函数调度框架)

Spring Boot 2.x examples

Sample Spring Cloud microservices e-shop.

An example Event-Driven application in Go built with Watermill library.

Using Go & MySQL & Docker & Web Socket & gRPC & Kafka & Zookeeper & Protobuf. Distributed and Scalable Open Judge System for Algorithms.

Based on the proxy gateway service of dubbo-go, it solves the problem that the external protocol calls the internal Dubbo cluster. At present, it supports HTTP and gRPC[developing].

Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.

ChanBroker, a Broker for goroutine, is simliar to kafka

sample spring cloud application that integrates with rabbitmq through spring cloud stream framework as shows how to setup message-driven microservices basing on publish-subscribe model, consumer groups

Data Analysis Using Hadoop/Spark/Storm/ElasticSearch/MachineLearning etc. This is My Daily Notes/Code/Demo. Don't fork, Just star !

No description or website provided.

Example Docker Cluster for "Full Stack Monitoring and Notification with Prometheus and Grafana"

The Internals of Apache Kafka

Kafka Connect connectors for Azure Cosmos DB

Apache Camel Kafka Connector Examples

Flask Kafka consumer full implementation example. Ideal for a microservices architecture.

📺 OpenReplay is developer-friendly, open-source session replay.

SpringBoot商城系统Demo，主要功能：提供了商城系统的后端Api，不包含前端页面，体现了前后端解耦分离的思想。实现了商品，购物车，订单系统，单点登录系统等4个功能模块

A convenience library for Apache Kafka integration in a Dropwizard service.

Template for Akka Streams & Kafka. Default impl: mirror a topic onto another one

Professionally supported Zipkin + OpenTracing driver in C#

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading support.

POC de uma aplicação de domínio financeiro.

Kafka De/Serializer using avro and Confluent's Schema Registry

Java 实践代码，多线程，数据结构，算法，设计模式，Spring，RabbitMQ ,RocketMQ

JUnit rule for spinning up a Kafka broker

Java并发编程与高并发解决方案：http://coding.imooc.com/class/195.html Java开发企业级权限管理系统：http://coding.imooc.com/class/149.html

Standalone alternatives to Kafka Connect Connectors

Scalable package delivery logistics simulator built using SingleStore and Vectorized Redpanda

后端面试题汇总（Python、Redis、MySQL、PostgreSQL、Kafka、数据结构、算法、编程、网络）

Development repository for the kafka cookbook

Account Registration and Confirmation. Exception Handling. Caching with Redis.Mail sender by Apache Kafka.Notification send with RabbitMq.

Expose Kafka offset lag to prometheus

Multi docker container images for main Big Data Tools. (Hadoop, Spark, Kafka, HBase, Cassandra, Zookeeper, Zeppelin, Drill, Flink, Hive, Hue, Mesos, ... )

Storm Kafka 流数据 处理系统

Data pipeline project

Kafka Connect Examples

Stream Processing Made Easy