kafka

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.

Strimzi canary

Using KarateDSL to test Kafka applications

A .NET Core Kafka sample application using Vertical Slice Architecture

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

Kafka Connect Connector for Jenkins Open Source Continuous Integration Tool

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实现的数据实时流式同步的应用,支持高可用

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

Event sourcing in java with vavr, akka stream and vertx reactive PG driver

Kafka on Kubernetes with Strimzi

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

Fully Managed Apache Kafka Cluster with Ansible & Terraform.

Apache flink

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

🌀 Ultimate Docker Compose to rule them all.

Freeswitch Kafka Plugin

Kafka Connect Store Partitioner by custom fields and time

Motor.NET is a microservice framework based on Microsoft.Extensions.Hosting

A Kafka Cookbook for Chef

An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka

Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"

A library to build streaming applications that consume from and produce to Kafka.

Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)

Pan is a high performance mq proxy,support kafka,rabbit-mq,rocketmq,nsq and other mq

A DNS server written in Go with an event stream architecture, updated via kafka

Stream your process history to Kafka

A Kafka Connect source connector that generates data for tests

yet another databus that transfer/transform pipeline data between plugins

Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink

ARM64 compatible images of confluent-platform

Export events from Zeebe to Kafka

ksqldb-go client

Components for building stream loaders from Kafka to arbitrary storages

Utility tool for managing kafka

Sandwich Daemon is the middle man between discord and your microserviced bot. Handles gateway, state and provides a dashboard.

Terraform module which creates Msk Kafka Cluster on AWS

基于Spark的实时推荐系统,使用MovieLens作为测试数据集

Kafka REST proxy

Real-time vehicle telematics analytics demo using OmniSci

RELK -- The Research Elastic Stack (Kafka, Beats, Zookeeper, Logstash, ElasticSearch, Kibana, Spark, & Jupyter -- All in Docker)

A Kafka adapter for the php-pubsub package

A collection of runnable and self-contained examples from various akka-streams and Alpakka docs, tutorials and blogs

Developer Workshops related to the Java development on OpenShift

Java (Spring) microservices example with Kafka and saga pattern