{"repo":"streamdal/plumber","free":true,"listed":false,"github":"https://github.com/streamdal/plumber","clone":"git clone https://github.com/streamdal/plumber.git","description":"A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.","language":"Go","stars":2156,"topics":["event-driven","kafka","rabbitmq","message-queue","message-bus","event-bus","protobuf","golang","hacktoberfest"],"license":"MIT","category":"data-pipelines","readme_excerpt":"plumber is a CLI devtool for inspecting, piping, messaging and redirecting data in message systems like Kafka, RabbitMQ , GCP PubSub and many more. \\[1] The tool enables you to: Safely view the contents of your data streams Write plain or encoded data to any system Route data from one place to another Decode protobuf/avro/thrift/JSON data in real-time Support for both Deep and Shallow protobuf envelope types Support for google.protobuf.Any fields Relay data to the Streamdal platform Ship change data capture events to Streamdal platform Replay events into a message system on your local network And many other features (for a full list: plumber -h ) \\[1] It's like curl for messaging systems. Why do you need it? Messaging systems are black boxes - gaining visibility into what is passing through them is an involved process that requires you to write brittle consumer code that you will eventually throw away. plumber enables you to stop wasting time writing throw-away code - use it to look into your queues and data streams, use it to connect disparate systems together or use it for debugging your event driven systems. Demo Install Via brew Manually macOS Linux Windows Plumber is a single binary, to install you simply need to download it, give it executable permissions and call it from your shell. Here's an example set of commands to do this: Usage Write messages Read message(s) NOTE: Add -f to perform a continuous read (like tail -f ) Write messages via pipe Write multiple messages ","default_branch":null,"files":null,"tree":[],"storefront":"/r/streamdal","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/streamdal/plumber/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}