Message queue tracing (Kafka, RabbitMQ, NATS)

[ibrahimcesar]

Trace async operations through message queues for event-driven architectures.

Goals

• Track messages through queue systems
• Maintain trace context across producers/consumers
• Support popular message queue systems

Supported Systems

• Apache Kafka (rdkafka crate)
• RabbitMQ (lapin crate)
• NATS (async-nats crate)

Features

• Automatic context injection in message headers
• Consumer trace context extraction
• Message timing and queue latency
• Partition/queue visibility

Acceptance Criteria

• Traces flow through message queues
• Producer-consumer relationship visible
• Queue latency measured
• Works with competing consumers