882 Open source projects that are alternatives of or similar to Openmessaging Benchmark

Write your Spark data to Kafka seamlessly

PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

Use Kafka as a remote storage database for Prometheus (remote write only)

Example Docker setup for a Django app behind an Nginx proxy with Celery workers

A Prometheus exporter for NATS metrics

Kafka ecosystem ... but step by step!

MongoDB Kafka Connector

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.

Collection of Kubernetes Operators built with KUDO.

大数据分析可视化实践

The boilerplate of the GoLang application with a clear microservices architecture.

Sample Event Sourcing implementation with .NET Core

Async/await first CQRS+ES and DDD framework for .NET

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Java SDK for CloudEvents

Repository for my java projects.

Elixir AMQP consumer and publisher behaviours

汇总java生态圈常用技术框架、开源中间件，系统架构、数据库、大公司架构案例、常用三方类库、项目管理、线上问题排查、个人成长、思考等知识

一些基础服务的docker-compose配置文件，方便在一台新电脑上快速开始工作

Everything about Apache Kafka

Kafka Tutorials microsite

.NET Stream Processing Library for Apache Kafka 🚀

DC/OS SDK is a collection of tools, libraries, and documentation for easy integration of technologies such as Kafka, Cassandra, HDFS, Spark, and TensorFlow with DC/OS.

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

Cluster RabbitMQ (official docker image)

☁️ 👀 💬 Visual Chatbot

Apache Kafka on Docker

This is a simple spring-boot app that shows how to configure easily RabbitMQ with AMQP for producing and consuming messages in default format and JSON.

rocketmq-spring-boot-starter

Lightweight, fault-tolerant message streams.

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Instagram Clone - Cloning Instagram for learning purpose

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

RabbitMQ为异步消息处理提出了一个很好的解决方案，它是一个非常好用的消息中间件，主要用于中间件的解耦，同时，Spring Boot为RabbitMQ提供了支持, Spring Boot为Rabbit准备了spring-boot-starter-amqp，spring-rabbit 支持 AMQP(即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准)，并且为RabbitTemplate和RabbitMQ提供了自动配置选项

Big Data Toolkit for the JVM

Confluent REST Proxy for Kafka

A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch

Domain Driven Design oriented application framework, meets CRUD needs

纯托管轻量级RocketMQ客户端，支持发布消息、消费消息、负载均衡等核心功能！

♨️ DDD in Java skeleton & examples. Course:

Simple AMQP wrapper around github.com/streadway/amqp

Playground for Kafka/Confluent Docker experimentations

Dump messages from a RabbitMQ queue to files, without affecting the queue.

Kombu is a messaging library for Python.

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

Command Line Tool for managing Apache Kafka

Angular 6 and 7 - Stomp service over Websockets

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

Message Queue & Broker Injection tool

RabbitMQ Plugin for filtering message duplicates

个人学习 SpringBoot2.x 写的一些示例程序，目前正在持续更新中.....

Syslog Collector written in Go, streams to Kafka 0.8

RabbitMQ wire tap and swiss army knife

Apache Kafka bridge

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Apache RocketMQ Operator

WaterDrop is a standalone Karafka component library for generating Kafka messages

Aliyun Open Notification Service Client

Simplifying Kafka for ruby apps