ibrahimcesar/async-inspect

Message queue tracing (Kafka, RabbitMQ, NATS)

Open

#33 opened on Nov 29, 2025

View on GitHub
 (0 comments) (0 reactions) (0 assignees)Rust (1 fork)auto 404
distributedenhancementhelp wanted

Repository metrics

Stars
 (5 stars)
PR merge metrics
 (PR metrics pending)

Description

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

Contributor guide