1829 Open source projects that are alternatives of or similar to Benthos

Building event-driven applications the easy way in Go.

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

[READ-ONLY] Message queue bundle for Symfony. RabbitMQ, Amazon SQS, Redis, Service bus, Async events, RPC over MQ and a lot more

A lightweight stream processing library for Go

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

OpenSleigh is a Saga management library for .NET Core.

DDD. Event sourcing. CQRS. REST. Modular. Microservices. Kotlin. Spring. Axon platform. Apache Kafka. RabbitMQ

A MessageBus (CommandBus, EventBus and QueryBus) implementation in PHP7

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

Simple service bus for sending events between processes using amqp.

My own version of r/place, done in a weekend

A simple and eloquent workflow for streaming messages to micro-services.

EventMesh is a dynamic event-driven application runtime used to decouple the application and backend middleware layer, which supports a wide range of use cases that encompass complex multi-cloud, widely distributed topologies using diverse technology stacks.

Sample using micro services in .NET Core 3.1 Focusing on clean code

Learn Clean Architecture with .NET Core 3.0 🔥

Example of a list-making Web API using CQRS, Event Sourcing and DDD.

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

A list about Apache Kafka

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.

A PHP client for the NATSio cloud messaging system.

Asp.Net Core 5 Clean Architecture (Microservices, Modular Monolith, Monolith) samples (+Blazor, Angular 11, React 17, Vue 2.6), Domain-Driven Design, CQRS, Event Sourcing, SOLID, Asp.Net Core Identity Custom Storage, Identity Server 4 Admin UI, Entity Framework Core, Selenium E2E Testing, SignalR Notification, Hangfire Tasks Scheduling, Health Checks, Security Headers, ...

OpenMessaging Benchmark Framework

Experimental CQRS and Event Sourcing service

This repo contains a sample application based on a Garage Management System for Pitstop - a fictitious garage. The primary goal of this sample is to demonstrate several software-architecture concepts like: Microservices, CQRS, Event Sourcing, Domain Driven Design (DDD), Eventual Consistency.

DDD+CQRS+Event-sourcing examples using EventFlow following CQRS-ES architecture. It is configured with RabbitMQ, MongoDB(Snapshot store), PostgreSQL(Read store), EventStore(GES). It's targeted to .Net Core 2.2 and include docker compose file.

Multi tenant SaaS starter kit with cqrs graphql microservice architecture, apollo federation, event source and authentication

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

Go simple async message bus

The magic message bus

Event-Driven microservices with Kafka Streams

Single repository for go-nats example code. This includes all documentation examples and any common message pattern examples.

Source code for the Kafka Streams in Action Book

Message bus and queue for Mezzio with Symfony Messenger + Enqueue

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 will be deprecated. See the README.md file for hints to alternative toolkits.

Sample Application DDD, Reactive Microservices, CQRS Event Sourcing Powered by DERMAYON LIBRARY

Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes

A module that makes the process of consuming and publishing messages in message brokers easier

Versatile Data Kit (VDK) is an open source framework that enables anybody with basic SQL or Python knowledge to create their own data pipelines.

Flight ticket booking system implemented with CQRS and ES.

A schema-aware Scala library for data transformation

Interoperable GRPC based publish/subscribe

Demo application focusing on the Food Ordering domain - Used in our video series

AMQP Pub/Sub for the Watermill project.

This is tutorial project to learn how to connect Symfony4 and docker compose with Domain Driven Design and Event Sourcing

🐳 A playground for Docker with RabbitMQ and Node.

Simple API for spawning RabbitMQ Producers and Consumers.

Node.js library for interacting with RabbitMQ based on RxJS streams

Real-Time Event Streaming & Change Data Capture

Dockerized skeleton for prooph software Event Machine

A python package to create a database on the platform using our moj data warehousing framework

[READ-ONLY] The queue-interop compatible AMQP protocol impl. Based on bunny/bunny lib

🦈✨ C# DDD Skeleton: Bootstrap your new C# projects applying Hexagonal Architecture and Domain-Driven Design patterns

CQELight is an entreprise grade extensible and customisable framework for creating software with CQRS, DDD & Event Sourcing patterns

auto reconnecting example for github.com/streadway/amqp Connection & Channel

A Symfony bundle for basic EAV management

Event Sourcing and CQRS in practice.

A simple Python Flask combined with RabbitMQ pika library

Golang AMQP on steroids. Reliable connection. Publisher. Consumer.

CQRS + Event Sourcing library for PHP

.Net Microservice Application