Overview
event-trace provides automatic correlation ID propagation across message broker and HTTP boundaries. It instruments Kafka consumers and producers, RabbitMQ channels, and HTTP clients without requiring manual trace context management.
Quick Start
import "github.com/example/event-trace"
// Wrap your Kafka consumer
consumer := eventtrace.WrapConsumer(kafkaConsumer,
eventtrace.WithOTLP("http://otel-collector:4317"),
)
Features
- Zero-config correlation ID propagation for Kafka and RabbitMQ
- OpenTelemetry OTLP export
- HTTP middleware for Express, Gin, and Echo
- Baggage propagation across async boundaries
- Sampling rate configuration per topic or queue