743 Open source projects that are alternatives of or similar to Kmq

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

A daily digest of the articles or videos I've found interesting, that I want to share with you.

Open-source IoT Platform - Device management, data collection, processing and visualization.

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Example projects building Reactive Integrations using Alpakka

提供清晰、实用的Akka应用指导

RabbitMq client in Scala and Akka actors

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

Fancy stream processing made operationally mundane

a fast and simple distributed publish-subscribe messaging system (mq)

Akka gRPC

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

Reactive Streams API for Serial Communication

Akka Stream library for Azure IoT Hub

Throughput and latency monitoring for Akka Streams

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

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

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

Clickhouse Scala Client with Reactive Streams support

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

A PHP client for the NATSio cloud messaging system.

An actor framework for Go

⚡️ Nepxion Thunder is a distribution RPC framework based on Netty + Hessian + Kafka + ActiveMQ + Tibco + Zookeeper + Redis + Spring Web MVC + Spring Boot + Docker 多协议、多组件、多序列化的分布式RPC调用框架

我的个人技术博客（Python、Django、Docker、Go、Redis、ElasticSearch、Kafka、Linux）

Kryo-based serialization for Akka

🌴 A chinese guide of Akka, based on Java.

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required

Go client library for Apache Kafka

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

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

A simple high-performance Redis message queue for Node.js.

Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka

A C client for NATS

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

Advanced monitoring for Sidekiq

💪 example of common used libraries and frameworks, programming required, don't fork man.

Sync data from the other DB to ClickHouse(cluster)

Apache Kafka running on Kubernetes

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

♒︎ [WIP] An experimental ~distributed~ commit-log

franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+. Producing, consuming, transacting, administrating, etc.

Coordinated (etcd, ...) cluster construction for dynamic (cloud, containers) environments

推荐项目（实时推荐和离线推荐）

Distributed web chat application base websocket built on akka.

An Intuitive Event-Driven Reactive Programming Library for Java

Streaming reactive and dataflow graphs in Python

syncClient，数据实时同步中间件（同步mysql到kafka、redis、elasticsearch、httpmq）！

Akka Management is a suite of tools for operating Akka Clusters.

amazonriver 是一个将postgresql的实时数据同步到es或kafka的服务

JVM Bloggers - website and newsletter with JVM blogs from Poland

A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases.

Serverless Platform for the stateful services

istio 微服务示例代码 grpc+protobuf+echo+websocket+mysql+redis+kafka+docker-compose

Learn Clean Architecture with .NET Core 3.0 🔥

以教学为目的的电商系统。包含ToB复杂业务、互联网高并发业务、缓存应用；DDD、微服务指导。模型驱动、数据驱动。了解大型服务进化路线，编码技巧、学习Linux，性能调优。Docker/k8s助力、监控、日志收集、中间件学习。前端技术、后端实践等。主要技术：SpringBoot+JPA+Mybatis-plus+Antd+Vue3。

Best practice for hangfire samples

Reactive (RSocket/gRPC) Gateway for the event-based systems

Big Data Processing Framework - Unified Data API or SQL on Any Storage

C# 开发辅助类库，和士官长一样身经百战且越战越勇的战争机器，能力无人能出其右。

Thin Scala wrapper around Kafka Streams Java API