A terminal UI for inspecting and managing message queues across RabbitMQ, Kafka, and MQTT.
Browse queues, read messages, publish, diff, dump, replay, and manage your brokers — all from the terminal. Wizard-style drill-down flow: Profiles -> Queues -> Messages -> Detail.
- Multi-broker — RabbitMQ (Management API), Kafka (librdkafka), MQTT (rumqttc)
- Non-destructive peek — RabbitMQ uses ack_requeue_true; Kafka uses ephemeral consumers
- Message operations — publish, copy, move, delete, export, import, diff, replay
- Multi-select — bulk operations on selected messages with visual checkboxes
- Smart decode — JSON/XML pretty-print, base64/gzip auto-decode, Avro via Schema Registry, Protobuf raw decode
- Exchange management — browse, create, delete exchanges and bindings (RabbitMQ)
- Queue management — purge, delete, compare queues, topology view, consumer groups
- Payload search — vim-style
/search withn/Nnavigation and highlighted matches - Monitoring — sparklines, auto-refresh, tail mode, webhook alerts with regex matching
- Pretty export —
Shift+Eexports JSON with fully indented nested bodies - File browser — directory navigation popup for export and import operations
- Benchmarking — concurrent flood-publish with p50/p95/p99 latency percentiles
- DLQ workflows — x-death header parsing, one-click re-route to original exchange
- 5 color themes — with live preview picker
- Scheduling — delayed message publishing with persistent timers
Download from GitHub Releases — available for macOS (ARM/Intel), Linux (x86), and Windows (x86/ARM). For Linux ARM, install via cargo install or build from source.
# Requires cmake for librdkafka
cargo install queuepeekgit clone https://github.com/matutetandil/queuepeek.git
cd queuepeek && cargo build --release
./target/release/queuepeekqueuepeek checks for updates automatically. When a new version is available, a hint appears in the status bar — press Shift+U to update in place.
# ~/.config/queuepeek/config.toml
[profiles.local]
type = "rabbitmq"
host = "localhost"
port = 15672
username = "guest"
password = "guest"
vhost = "/"
[profiles.kafka-dev]
type = "kafka"
host = "localhost"
port = 9092
[profiles.kafka-dev.schema_registry]
url = "http://localhost:8081"See the full configuration guide for TLS, MQTT topics, webhook alerts, templates, and more.
| Key | Queue list | Message list | Detail | Exchanges |
|---|---|---|---|---|
j/k |
Navigate | Navigate | Scroll | Navigate |
Enter |
Open queue | Open message | — | Expand/collapse |
/ |
Filter | Filter | Search payload | Filter |
Shift+P |
Publish | Publish | — | — |
p |
— | — | Pretty-print | — |
b |
— | — | Base64/gzip decode | Create binding |
s |
— | — | Schema Registry decode | — |
e/Shift+E |
— | Export / pretty | — | — |
Space |
— | Toggle select | — | — |
i |
Queue info | — | — | Exchange info |
Shift+G |
Consumer groups | — | — | — |
Shift+X |
Exchange mgmt | — | — | — |
a |
— | — | — | Create exchange |
Shift+D |
Delete queue | Delete selected | — | Delete exchange |
d |
— | Diff two msgs | — | Delete binding |
F5 |
Benchmark | — | — | — |
n/Shift+N |
— | — | Next/prev match | — |
f |
Fetch preset (persistent) | Fetch preset (persistent) | — | — |
Shift+F |
Load N once | Load N once | — | — |
? |
Help | Help | Help | Help |
Esc |
Back | Back/clear | Back | Back to queues |
Ctrl+Q |
Quit | Quit | Quit | Quit |
See the full keyboard reference for all shortcuts.
- Configuration — profiles, TLS, Schema Registry, webhooks, templates
- Keyboard shortcuts — complete key reference per screen
- Backends — RabbitMQ, Kafka, MQTT details and operation matrix
- Features — deep dive into every feature
- Architecture — codebase structure and design patterns
ratatui | crossterm | rdkafka | rumqttc | reqwest | apache-avro
If queuepeek saves you time, you can buy me a coffee ☕
MIT