kafka

Govern Service RPC & Event-Driven Architecture Framework || Govern EventBus is no longer maintained, please use Wow instead.

A repository stores some dockerfiles or docker-compose files for quickly starting service or service cluster.

A collection of examples to demonstrate how to interact with Redpanda from various clients and languages.

☝️Implement all kafka protocols, providing 'HighLevel' and 'LowLevel' client apis respectively, and utilize swoole to realize collaboration and flexib...

:musical_score: Docker compose files for various kafka stacks

Test suite for Kafka Connect connectors based on Landoop's Coyote and docker.

Kafka REST UI 🍄

Kafka Connector for DynamoDB [unmaintained]

:penguin:基于spark streaming+flume+kafka+hbase的实时日志处理分析系统(分为控制台版本和基于springboot、Echarts等的Web UI可视化版本)

springboot集成kafka

Reactive Streams framework with support for at-least-once processing

Scheduler for low-frequency and long-term scheduling of delayed messages to Kafka topics.

flink详细学习实践

Kafka Configs Metrics Exporter for Prometheus

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

DataFibers Data Service

Fast kafka client for asyncio

Kafka Connect Connector for Jenkins Open Source Continuous Integration Tool

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

电影推荐系统

Utility project for working with Kafka Connect.

A kafka-connect REST api client for java

Move your messages from MQTT to Apache Kafka in real-time :rocket:

Run dev environments easily and fastly using docker

WASP is a framework to build complex real time big data applications. It relies on a kind of Kappa/Lambda architecture mainly leveraging Kafka and Spa...

Example project for Spring Boot + Apache Kafka + Docker-compose solution

Demo illustrating the usage of Spring Cloud Stream in order to integrate with Kafka Streams

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit wil...

My NixOps / NixOs experiments ( #k8s , #elk, #kafka / #zk clusters and #RaspberryPi3)

A SQL-like language for performing ETL transformations.

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

Industrial IoT (IIoT) Integration and Data Processing with Apache PLC4X, Kafka Connect, KSQL (OPC-UA, Modbus, Siemens S7)

Push Notification and Real Time Notification application on Angular 5, NodeJS, Apache Kafka, MongoDB with Spring Boot App

A Saga Pattern implementation with Kafka, MongoDb and Python.

A Kafka client library for Erlang/Elixir based on librdkafka implemented as a safe Rust NIF.

A .NET Core Kafka sample application using Vertical Slice Architecture

Using KarateDSL to test Kafka applications

Strimzi canary

Go event sourcing with Kafka, example project

Kafka mongo connector (deeply inspired by https://github.com/DataReply/kafka-connect-mongodb)

✨ A message queue client framework (Kafka & ActiveMQ & RocketMQ)

💡 Modern Fullstack Application for Sharing Fastlane Ideas

基于Akka实现的数据实时流式同步的应用,支持高可用

yet another databus that transfer/transform pipeline data between plugins

Kafka on Kubernetes with Strimzi

CQRS implementation using Debezium + Spring Cloud Stream + Kafka Connect + Kafka + Druid

Fully Managed Apache Kafka Cluster with Ansible & Terraform.

End-to-end Snowplow Analytics Pipeline for real time events

Kafka Connect Store Partitioner by custom fields and time

🌀 Ultimate Docker Compose to rule them all.