301.smooks / smooks
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
- java
- smooks
- enterprise-integration
- etl
- sax
- pipelines
- +5 more
+6 stars
from 416 · score 1.95
Trending repositories
Ranked by Attention Score: stars gained over the last 180 complete days
301–389 of 389 by Attention Score · May 8, 2026 – Nov 3, 2026 (UTC)
302.eigr / spawn
Spawn - Actor Mesh
- actorsystem
- concurrency
- distributed-systems
- kubernetes
- sidecar
- actor-model
- +8 more
+6 stars
from 371 · score 1.95
303.neo4j / neo4j-spark-connector
Neo4j Connector for Apache Spark, which provides bi-directional read/write access to Neo4j from Spark, using the Spark DataSource APIs
- spark
- neo4j-connector
- cypher
- neo4j-driver
- bolt
- hacktoberfest
+6 stars
from 318 · score 1.95
304.mehdihadeli / Go-MediatR
🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.
- cqrs
- golang
- mediator
- mediator-pattern
- go
- golang-package
+6 stars
from 276 · score 1.95
305.chronicle-app / chronicle-etl
📜 A CLI toolkit for extracting and working with your digital history
+6 stars
from 194 · score 1.95
306.SomajitDey / ipfs-chat
Real-time P2P messenger using go-ipfs pubsub. TUI. End-to-end encrypted texting & file-sharing. NAT traversal.
- p2p
- tui
- ipfs
- pubsub
- serverless
- dht
- +14 more
+6 stars
from 149 · score 1.95
307.AdaCore / RecordFlux
Formal specification and generation of verifiable binary parsers, message generators and protocol state machines
- parser
- binary-parser
- ada
- spark
- formal-verification
- formal-specification
- +5 more
+6 stars
from 125 · score 1.95
308.groda / big_data
Big Data essentials: Hadoop, MapReduce, Spark. Explore tutorials and demos in Jupyter notebooks—most are self-contained and live, ready to run with a click.
+6 stars
from 83 · score 1.95
309.provero-org / provero
Declarative data quality engine. Define checks in YAML, run anywhere.
- airflow
- anomaly-detection
- data-contracts
- data-quality
- data-testing
- duckdb
- +6 more
+6 stars
from 11 · score 1.95
310.elastic / elasticsearch-hadoop
:elephant: Elasticsearch real-time search and analytics natively integrated with Hadoop
+5 stars
from 1,962 · score 1.79
311.espertechinc / esper
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
- cep
- complex-event-processing
- open-source
- compiler
- streaming-sql
- espertech
- +3 more
+5 stars
from 871 · score 1.79
312.jakubkulhan / bunny
Performant pure-PHP AMQP (RabbitMQ) sync/async (ReactPHP) library
- amqp
- amqp-client
- amqp0-9-1
- php
- php-library
- rabbitmq
+5 stars
from 742 · score 1.79
313.mrpowers-io / quinn
pyspark methods to enhance developer productivity 📣 👯 🎉
+5 stars
from 685 · score 1.79
314.elpheria / rpc-websockets
JSON-RPC 2.0 implementation over WebSockets for Node.js and JavaScript/TypeScript
- rpc-api
- rpc-framework
- rpc-client
- rpc-server
- websocket-server
- rpc
- +14 more
+5 stars
from 621 · score 1.79
315.boostercloud / booster
Booster Framework
- serverless
- cloud-native
- booster-framework
- typescript
- event-driven
- event-sourcing
- +9 more
+5 stars
from 442 · score 1.79
316.AntonioFalcaoJr / EventualShop
A state-of-the-art distributed system using Reactive DDD as uncertainty modeling, Event Storming as subdomain decomposition, Event Sourcing as an eventual persistence mechanism, CQRS, Async Projections, Microservices for individual deployable units, Event-driven Architecture for efficient integration, and Clean Architecture as domain-centric design
- cqrs
- ddd
- clean-architecture
- event-sourcing
- event-driven
- eda
- +14 more
+5 stars
from 419 · score 1.79
317.tigase / tigase-server
Highly optimized, extremely modular and very flexible XMPP/Jabber server
- tigase
- xmpp
- server
- java
- jabber
- iot
- +7 more
+5 stars
from 353 · score 1.79
318.dbcli / athenacli
AthenaCLI is a CLI tool for AWS Athena service that can do auto-completion and syntax highlighting.
- aws-cli
- athena-cli
- aws-athena
- python
- bigdata
- syntax-highlighting
- +3 more
+5 stars
from 223 · score 1.79
319.mostafa / xk6-kafka
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
+5 stars
from 214 · score 1.79
320.PierreCapo / treeviz
Tree diagrams with JavaScript :evergreen_tree: :chart_with_upwards_trend:
- tree
- javascript
- visualization
- big-data
- hierarchy
- family-tree
- +1 more
+5 stars
from 171 · score 1.79
321.helgeho / ArchiveSpark
An Apache Spark framework for easy data processing, extraction as well as derivation for web archives and archival collections, developed at Internet Archive.
- archivespark
- spark-framework
- spark
- web-archiving
- webarchive
- internet-archive
- +1 more
+5 stars
from 159 · score 1.79
322.etlkit / etlkit
EtlKit is a lightweight ETL (extract · transform · load) library and data integration toolbox for .NET. Build your own data pipelines programmatically in C# — readable, testable, and tracked in source control like the rest of your code.
- dotnet
- dotnet-core
- etl
- etl-framework
+5 stars
from 31 · score 1.79
323.wisp-trading / wisp
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
- algorithmic-trading
- cryptocurrency
- event-driven
- go
- golang
- trading-algorithms
- +2 more
+5 stars
from 9 · score 1.79
324.mgillr / crdt-merge
Conflict-free merge for DataFrames, JSON, ML models & distributed agents — powered by CRDTs. The first merge library where every operation is mathematically guaranteed to converge.
- collaborative-editing
- conflict-resolution
- crdt
- data-engineering
- data-synchronization
- distributed-systems
- +14 more
+5 stars
from 2 · score 1.79
+4 stars
from 3,480 · score 1.61
326.onyx-platform / onyxArchived
Distributed, masterless, high performance, fault tolerant data processing
- clojure
- distributed
- streaming
- batch
- data
+4 stars
from 2,045 · score 1.61
327.pinterest / secorArchived
Secor is a service implementing Kafka log persistence
+4 stars
from 1,854 · score 1.61
328.PatMartin / Dex
Dex : The Data Explorer -- A data visualization tool written in Java/Groovy/JavaFX capable of powerful ETL and publishing web visualizations.
- data-science
- data-visualization
- visualization
- data-analysis
- data-mining
- java
- +7 more
+4 stars
from 1,314 · score 1.61
329.nats-io / nats.net.v1
The official C# Client for NATS
+4 stars
from 649 · score 1.61
330.polyaxon / traceml
Engine for AI/ML/Data tracking, visualization, explainability, drift detection, and dashboards for Polyaxon.
- pandas
- pandas-summary
- dataframes
- data-science
- spark
- dask
- +14 more
+4 stars
from 529 · score 1.61
331.adidas / api-guidelines
adidas group API design guidelines
+4 stars
from 400 · score 1.61
332.BEagle1984 / silverback
Silverback is a message bus and broker integration library for .NET. It is designed to simplify event-driven architectures and asynchronous messaging, with first-class support for Apache Kafka and MQTT.
- microservice
- messaging
- kafka
- silverback
- message-bus
- message-brokers
- +6 more
+4 stars
from 279 · score 1.61
+4 stars
from 246 · score 1.61
334.monksy / awesome-kafka
A collection of kafka-resources
- kafka
- kafka-streams
- awesome
- awesome-list
- awesome-lists
+4 stars
from 212 · score 1.61
335.archivesunleashed / aut
The Archives Unleashed Toolkit is an open-source toolkit for analyzing web archives.
- spark
- hadoop
- webarchives
- analysis
- apache-spark
- scala
- +8 more
+4 stars
from 155 · score 1.61
336.Steema / TeeBI
Data-mining and Visualization components for RAD Studio
- visualization
- complex-structures
- database
- charting-library
- multidimensional-data
- query-engine
- +7 more
+4 stars
from 148 · score 1.61
337.docandrew / CuBit
General-purpose, formally-verified, 64-bit operating system in SPARK/Ada for x86-64
+4 stars
from 86 · score 1.61
338.joseferben / pocketbase-queue
A type-safe queue for background tasks using PocketBase.
- background-jobs
- pocketbase
- queue
- typescript
- workers
+4 stars
from 60 · score 1.61
339.apache / incubator-heronArchived
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
+3 stars
from 3,620 · score 1.39
340.chrislusf / glow
Glow is an easy-to-use distributed computation system written in Go, similar to Hadoop Map Reduce, Spark, Flink, Storm, etc. I am also working on another similar pure Go system, https://github.com/chrislusf/gleam , which is more flexible and more performant.
+3 stars
from 3,213 · score 1.39
341.killme2008 / Metamorphosis
A high available,high performance distributed messaging system.
+3 stars
from 1,325 · score 1.39
342.lensacom / sparkit-learn
PySpark + Scikit-learn = Sparkit-learn
+3 stars
from 1,147 · score 1.39
343.rdagumampan / yuniql
Free and open source schema versioning and database migration made natively with .NET/6. NEW THIS MAY 2022! v1.3.15 released!
- sql
- yuniql
- database-migrations
- sqlserver
- postgresql
- mariadb
- +10 more
+3 stars
from 427 · score 1.39
344.grai-io / grai-core
The repository host gives no description.
- hacktoberfest
- data
- datalineage
- dbt
- open-source
- postgresql
- +11 more
+3 stars
from 314 · score 1.39
345.dereuromark / cakephp-queue
Queue plugin for CakePHP - simple, pure PHP and without dependencies.
- asynchronous
- background-jobs
- cronjob
- queue
- cakephp
- cakephp-plugin
- +1 more
+3 stars
from 306 · score 1.39
346.synacker / daggy
Daggy - Data Aggregation Utility and C/C++ developer library for data streams catching
- serverless-framework
- streaming
- stream-processing
- qt
- aggregation
- process
- +7 more
+3 stars
from 163 · score 1.39
+3 stars
from 145 · score 1.39
348.joel-jeremy / emissary
Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀
- java
- jvm
- messaging
- requests
- dispatcher
- event
- +2 more
+3 stars
from 107 · score 1.39
349.Timmoth / AsyncMonolith
Facilitates simple durable and asynchronous messaging in dotnet apps.
+3 stars
from 89 · score 1.39
350.ddd-cqrs-es / community
Docs related to DDD-CQRS-ES Discord Community
- community
- cqrs
- ddd
- event-sourcing
+3 stars
from 79 · score 1.39
351.capillariesio / capillaries
Distributed batch data processing framework
- cassandra
- rabbitmq
- go
- batch-processing
- dag
- distributed-computing
- +5 more
+3 stars
from 71 · score 1.39
352.lucabriguglia / Memoria
.NET framework for DDD, CQRS and Event Sourcing.
- cqrs
- event-sourcing
- ddd
- mediator
- dotnet
+3 stars
from 25 · score 1.39
353.godalida / koala-diff
Blazingly fast data comparison tool for Python, powered by Rust. Compare massive CSV/Parquet datasets instantly.
- csv
- data-engineering
- data-quality
- diff
- high-performance
- parquet
- +4 more
+3 stars
from 6 · score 1.39
354.ixian-platform / QuIXI
Quick integration toolkit for Ixian. Connects apps, IoT devices, AI Agents, and services to the Ixian Platform via REST APIs and message queues (MQTT/RabbitMQ). Provides developers with a simple bridge into secure Ixian communication and Client Discovery.
- api
- encryption
- integration
- iot
- message-queue
- messaging
- +14 more
+3 stars
from 5 · score 1.39
355.dataspoclab / dataspoc-pipe
Data ingestion engine — Singer taps to Parquet in cloud buckets
- data
- data-engineering
- data-lake
- duckdb
- etl
- parquet
- +3 more
+3 stars
from 1 · score 1.39
356.zalando / nakadiArchived
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
- java
- apis
- event-bus
- restful
- microservices
- postgresql
- +3 more
+2 stars
from 963 · score 1.10
357.OrleansContrib / Orleankka
Functional API for Microsoft Orleans http://orleanscontrib.github.io/Orleankka
- actors
- cqrs
- event-sourcing
- fsm
- orleans
- functional
+2 stars
from 504 · score 1.10
+2 stars
from 451 · score 1.10
359.lucas34 / SwiftQueue
Job Scheduler for IOS with Concurrent run, failure/retry, persistence, repeat, delay and more
+2 stars
from 420 · score 1.10
360.itlibrium / DDD-starter-dotnet
Sample implementation and comparison of various approaches to building DDD applications. Useful as a baseline to quickly start a DDD dot net project.
- ddd
- ddd-example
- ddd-patterns
- hexagonal-architecture
- bdd
- event-sourcing
- +1 more
+2 stars
from 403 · score 1.10
361.TeaEntityLab / fpGo
Monad, Functional Programming features for Golang
- golang
- functional-programming
- functional-reactive-programming
- reactive
- reactive-programming
- golang-library
- +14 more
+2 stars
from 353 · score 1.10
362.Hydrospheredata / mist
Serverless proxy for Spark cluster
+2 stars
from 323 · score 1.10
363.laurentpayot / verticalize
A pipe-like function to verticalize your JavaScript code
+2 stars
from 301 · score 1.10
364.vardius / message-bus
Go simple async message bus
- message-bus
- event-sourcing
- ddd
- async
- message-queue
- message-broker
- +4 more
+2 stars
from 282 · score 1.10
365.asc-lab / java-cqrs-intro
Examples of implementation CQRS with Event Sourcing - evolutionary approach
- cqrs
- java-11
+2 stars
from 212 · score 1.10
366.fulminate-io / machine
Machine is a workflow/pipeline library for processing data
- golang
- golang-library
- golang-package
- workflow
- workflow-engine
- pipeline
- +7 more
+2 stars
from 165 · score 1.10
367.eosrio / hyperion-history-api
Scalable Full History API Solution for Antelope (former EOSIO) based blockchains
- antelope
- api
- big-data
- blockchain
- elasticsearch
- eos
- +10 more
+2 stars
from 134 · score 1.10
368.flipkart-incubator / hbase-orm
A production-grade HBase ORM library that makes accessing HBase clean, fast and fun (Can also be used as Bigtable ORM)
- hbase
- orm
- mapreduce
- object-mapping
- hbase-orm
- bigtable
- +3 more
+2 stars
from 82 · score 1.10
369.wookey-project / ewok-kernel
A secure and high performances microkernel for building secure MCU-based IoTs
- ada
- microkernel
- embedded
- security
- microcontroller
- microcontroller-firmware
- +5 more
+2 stars
from 77 · score 1.10
370.apache / qpid-broker-j
Mirror of Apache Qpid Broker-J
- java
- qpid
- network-server
- apache
- amqp
- messaging
- +2 more
+2 stars
from 69 · score 1.10
371.biot2 / nats.pas
An Object Pascal Client for NATS
+2 stars
from 16 · score 1.10
+2 stars
from 10 · score 1.10
+1 stars
from 6,943 · score 0.69
374.twitter / summingbirdArchived
Streaming MapReduce with Scalding and Storm
+1 stars
from 2,120 · score 0.69
+1 stars
from 1,546 · score 0.69
+1 stars
from 1,311 · score 0.69
377.hazelcast / hazelcast-jetArchived
Distributed Stream and Batch Processing
- java
- big-data
- stream-processing
- batch-processing
- event-processing
- low-latency
- +3 more
+1 stars
from 1,110 · score 0.69
378.cloudera / livy
Livy is an open source REST interface for interacting with Apache Spark from anywhere
+1 stars
from 1,005 · score 0.69
379.CogComp / cogcomp-nlp
CogComp's Natural Language Processing Libraries and Demos: Modules include lemmatizer, ner, pos, prep-srl, quantifier, question type, relation-extraction, similarity, temporal normalizer, tokenizer, transliteration, verb-sense, and more.
- natural-language-processing
- nlp
- big-data
- data-mining
- cogcomp
- lemmatizer
- +12 more
+1 stars
from 478 · score 0.69
380.Code-Sharp / WampSharp
A C# implementation of WAMP (The Web Application Messaging Protocol)
+1 stars
from 388 · score 0.69
381.pawelkaczor / akka-ddd
Akka CQRS/ES framework
+1 stars
from 359 · score 0.69
382.davidesantangelo / api.rssArchived
RSS as RESTful. This service allows you to transform RSS feed into an awesome API.
+1 stars
from 346 · score 0.69
383.Creditas / kotlin-ddd-sampleArchived
A sample DDD/CQRS project using KOTLIN :beer:
- kotlin
- ddd
- cqrs
- axonframework
+1 stars
from 305 · score 0.69
384.scicloj / scicloj.mlArchived
A Clojure machine learning library
- machine-learning
- data-science
- data-pipeline
- hyperparameter-optimization
- classification
- regression
- +5 more
+1 stars
from 236 · score 0.69
385.peburrows / kane
Google Pub/Sub client for Elixir
+1 stars
from 106 · score 0.69
386.ballerina-platform / module-ballerina-mqtt
Ballerina MQTT Module.
+1 stars
from 104 · score 0.69
387.thinkbeforecoding / FsUnoArchived
Event sourcing implementation sample in F# - Moved to Codeberg
+1 stars
from 77 · score 0.69
388.eclipse-amlen / amlen
Message Broker for IoT/Mobile/Web. Mainly uses MQTT v3.x and v5. Aims to be easy to use, scalable and reliable
+1 stars
from 51 · score 0.69
389.LaunchPlatform / bq
BeanQueue, a lightweight Python task queue framework based on SQLAlchemy, PostgreSQL SKIP LOCKED queries and NOTIFY / LISTEN statements.
- postgresql
- python
- queue
- sqlalchemy
- worker
- task-queue
+1 stars
from 27 · score 0.69