opentelemetry_broadway

OpenTelemetry tracing for Broadway pipelines with support for distributed tracing.

Usage

Basic Setup

For basic Broadway instrumentation, set up the handler in your application's Application.start/2 callback:

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

  Supervisor.start_link(...)
end

With Trace Propagation

For Broadway pipelines that need distributed tracing with linked spans across services (extracts context from message headers and creates trace links):

def start(_type, _args) do
  # Enable trace propagation from message headers
  OpentelemetryBroadway.setup(propagation: true)

  Supervisor.start_link(...)
end

Installation

This library is available on Hex:

defp deps do
  [
    {:opentelemetry_broadway, "~> 0.3"}
  ]
end

Credit

This repository was originally created by Tom Taylor.