Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ.
- amqp
- rabbitmq
- rabbit
- golang
Repository Index
47,133 repositories indexed
409–432 of 534 · Most stars
Hadoop Data Integration with various databases, ftp servers, salesforce. Incremental update, dedup, append, merge your data on Hadoop.
Reactive Kafka Client for Vert.x
A symfony bundle for swarrot integration
- symfony
- bundle
- php
- symfony-bundle
Database synchronizer for Magento 2 (and Wordpress), based on Magerun2. Keeping development, staging and production in sync easily.
Docs related to DDD-CQRS-ES Discord Community
- community
- cqrs
- ddd
- event-sourcing
A tiny wrapper around NSQ topic and channel :rocket:
- nsq
- message-bus
- microservices
- go
Data validator agains Splunk Common Information Model (CIM)
Vert.x RabbitMQ Service
GoEventBus — high-performance event bus with a decision layer.
- golang
- library
- event-driven
- concurrency
Distributed batch data processing framework
Multi-core Window-Based Stream Processing Engine
- llvm
- incremental-computation
- aggregation
- stream-processing
Flume NG MongoDB source.
- flume
- sink
- mongodb
A set of open-source .NET libraries helping with DDD (domain-driven design) and CQRS (command query responsibility segregation).
- ddd
- cqrs
- nhibernate
- asp-net-core
Mirror of Apache Qpid Broker-J
- java
- qpid
- network-server
- apache
A go library for easy configure and run command chains. Such like pipelining in unix shells.
- golang
- go
- library
- command
Scramjet Platform is a distributed runtime supervisor that can run data processing programs called Sequences and manage local resources on any Linux server, Docker on small edge servers, and even large-scale Kubernetes clusters in the cloud or datacenters without exposing network ports to the public internet.
- nodejs
- stream-processing
- transform-as-a-service
- real-time
OCaml Amqp client library for Async and Lwt.
- amqp-client
- rabbitmq
- async
- ocaml
MQTT v5.0 full in Rust
Lightweight SQL-based stream processing engine for IoT edge.
Morphium - Mongodb Messaging and Java Object Mapper
A library that brings useful functions from various modern database management systems to Apache Spark
🇪🇺 Warehouse-native Analytics compatible with Google Analytics and Matomo tracking protocols. Ingest into ClickHouse, BigQuery or CSV/Parquet on S3/GCS/local fs while maintaining complete control over your data.
- clickhouse
- ga4
- tracker
- bigquery
Stream database events from PostgreSQL to Kafka
- postgresql
- events
- stream
- kafka