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

A SQS connector for Broadway

A RabbitMQ connector for Broadway

A Phoenix LiveDashboard page for inspecting your Broadway pipelines

A Kafka connector for Broadway

OpenTelemetry tracing for Broadway

A Google Cloud Pub/Sub connector for Broadway

A Faktory worker implementation for Elixir

A Broadway producer for an in-memory buffer.

A Jetstream client in pure Elixir.

A Redis Stream consumer for Broadway

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

Spawn is the core lib for Spawn Actors System

GenStage producers for EventStoreDB 20+ with Spear

An MQTT connector based on emqtt for Broadway.

Implementation of Broadway that supports a Kafka producer

An AMQP 1.0 connector for Broadway

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

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

A Aliyun MNS connector for Broadway

An opinionated Redis list connector for Broadway

Splunk producer for Broadway data processing pipelines

Download and warehouse historical trading data

Polyn framework for maintaining consistent event-based messages

A pure Elixir implementation of the AWS Java Kinesis Client Library (KCL)

Implementation of Broadway that supports a Kafka producer

Microsoft 365 Defender API Producer for Broadway

An event_bus data store building with Broadway.

A Sequin consumer for Broadway

Superintelligence Phoenix application