plumber

• Support for MQTT

  # Read (forever) example
  $ plumber read message mqtt --topic dantest  -d -f --line-numbers --address tcp://test.mosquitto.org:1883
  
  # Write example
  $ plumber write message mqtt --topic dantest --input-data testing --address tcp://test.mosquitto.org:1883
  
  # Read (forever) with protobuf
  $ plumber read message mqtt --topic dantest --address tcp://test.mosquitto.org:1883 -d -f --line-numbers --output-type protobuf --protobuf-dir ./test-assets/protos --protobuf-root-message Outbound
  
  # Write protobuf
  $ plumber write message mqtt --topic dantest --address tcp://test.mosquitto.org:1883 --input-file ./test-assets/messages/sample-outbound.json --input-type jsonpb --output-type protobuf --protobuf-dir ./test-assets/protos --protobuf-root-message Outbound
  

• Cleaned up debug info from output

Fairly significant cleanup release; significant refactor (moved to a diff lib); cleanup of some flags.

Added support for GCP PubSub.

• Added support to gzip decompress output on reads (from kafka and rabbit)
• Removed --exchange-name as required arg (forgot that rabbit has default exchange support)

This is the initial release of the port of our internal "plumber" tool that we use for consuming and publishing messages on our event bus.

It is nowhere near feature complete, but it does have the most important part implemented (in our opinion):

It is able to read and write protobuf based messages to either Kafka or RabbitMQ. We think that's pretty damn sweet.

We hope it's useful for you!