An MQTT connector based on emqtt for Broadway.

A utility to ensure an SQS queue exists before starting a Broadway pipeline.

An Off-Broadway producer enabling real-time ingestion of WebSocket data.

A Posthog SDK

Backstage is a CQRS & Event Sourcing framework optimized for Elixir applications to take advantage of concurrency and parallelism on the ...

A Sequin consumer for Broadway

An Elasticsearch connector for Broadway

A Broadway producer for an in-memory buffer.

An EventRelay Producer for Broadway

Broadway producer for PGMQ

OpenTelemetry tracing for Broadway

Implementation of Broadway that supports a Kafka producer

Mosql - MongoDB to Postgres data exporter

A Aliyun MNS connector for Broadway

Splunk producer for Broadway data processing pipelines

Microsoft 365 Defender API Producer for Broadway

Spawn is the core lib for Spawn Actors System

An AMQP 1.0 connector for Broadway

Polyn framework for maintaining consistent event-based messages

Off-Broadway producer for Telegram Bot API

A Phoenix LiveDashboard page for inspecting your Broadway pipelines

Download and warehouse historical trading data

SpiderMan,a fast high-level web crawling & scraping framework for Elixir

An event_bus data store building with Broadway.

A Redis Stream consumer for Broadway

GenStage producers for EventStoreDB 20+ with Spear

IntegrateDB is a database sharing system. It provides integration primitives and data ownership and migration controls. Use it to integra...

Prometheus metrics and Grafana dashboards for all of your favorite Elixir libraries

A beanstalkd connector for Broadway.

A Jetstream client in pure Elixir.