streamdal/plumber

Health v2 · maintenance only

Adoption not part of the score

2157 stars · 73 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

plumber is a single-binary CLI tool for inspecting, reading, writing, and piping data across messaging systems like Kafka, RabbitMQ, and GCP PubSub. It can decode protobuf, avro, thrift, and JSON payloads in real time and relay or replay events between systems.

Use cases

• read messages from a kafka topic from the command line
• write test messages to rabbitmq queue
• decode protobuf messages in a kafka stream
• pipe messages from one message queue to another
• debug event-driven systems without writing consumer code
• replay events into a local message system
• inspect contents of a pubsub topic

When to choose

• you need quick visibility into message queues without writing throwaway consumer code
• you want a single portable binary that supports many messaging backends
• you need to decode encoded payloads (protobuf/avro/thrift) on the fly
• you want to route or replay data between messaging systems

When to avoid

• you need a long-running production message pipeline with guarantees and monitoring
• you need a GUI dashboard for message streams
• you require a managed service rather than a local devtool

Facets

cli-tool · maturity active

message-queue cli serialization developer-tools streaming developer-tools cli windows go cross-platform kafka rabbitmq pubsub protobuf avro event-driven message-bus debugging single-binary messaging command-line data-engineering automation macos linux

Member repositories

For agents

markdown · JSON · MCP: product_card(name="streamdal/plumber")