Warning

This project has become an official OpenTelemetry integration, and this repo is no longer updated.

OpentelemetryBroadway

OpentelemetryBroadway uses telemetry handlers to create OpenTelemetry spans from Broadway events.

Installation

def deps do
  [
    {:opentelemetry_broadway, "~> 0.1"}
  ]
end

In your application start:

def start(_type, _args) do
  OpentelemetryBroadway.setup()

  # ...
end

Usage

A new trace is automatically started when a Broadway message is processed.

Handlers for message batches isn't currently supported.