Repository Index

Gatling plugin for Kafka

An Object Pascal Client for NATS

• delphi
• lazarus
• pascal
• linux

Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code

• business-process
• kafka
• kafka-streams
• micorservices

Elixir library to build Plug-like pipelines

• elixir
• pipeline
• plug

Abstraction layer for simple rabbitMQ connection, messaging and administration

• golang
• rabbitmq
• queue

A light-weight package for in-app micro batch processing

• batch
• batch-processing
• event-processing
• go

Declarative data quality engine. Define checks in YAML, run anywhere.

• airflow
• anomaly-detection
• data-contracts
• data-quality

Simple MQTT Client.

• mqtt
• client
• mqtt-client
• python

provides a Suricata Eve output for Kafka with Suricate Eve plugin

• suricata
• intrusion-detection

High performant ETL engine written in TypeScript

• data-processing
• etl
• etl-framework
• streaming-data

An event-driven library to manage and simulate Web Monetization.

• monetization
• web-monetization
• event-driven
• simulation

Apache Kafka Ada client library, based off of librdkafka

Common Lisp RabbitMQ client based on IOLib

• rabbitmq
• rabbitmq-client
• amqp
• common-lisp

A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.

• go
• kafka
• message-broker
• opentelemetry

Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets

• algorithmic-trading
• cryptocurrency
• event-driven
• go

Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.

• actor-model
• apache-flink
• distributed-systems
• event-driven

A detective for your data. Zero-config data quality monitoring — works with dbt, Postgres, BigQuery, Snowflake. No YAML.

• anomaly-detection
• bigquery
• cli
• data-engineering

ada privilege escalation

• ada
• security
• spark
• sudo

AsyncJob is an asynchronous queue job manager with light code, clear and speed. I hope so ! 😬

• async
• queue
• simple
• lightweight

Event Bus package for Go

• eventbus
• go
• golang
• pubsub

An open-source toolkit for analyzing line-oriented JSON Twitter archives with Apache Spark.

• spark
• tweets
• twitter-data
• twitter-json

🎲 Dotflow turns an idea into flow! — Lightweight Python library for execution pipelines

• etl
• etl-framework
• etl-pipeline
• python

The core libraries of the teknek stream processing platform

Gatling plugin for AMQP/RabbitMQ — publish, request-reply, and consume patterns with connection pooling

• amqp
• gatling
• gatling-plugin
• performance