plumber
plumber copied to clipboard
streamdal
A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.
Nats jetstream has a way to connect server by [nkey](https://github.com/nats-io/nats.go#new-authentication-nkeys-and-user-credentials), so could you guys help to add this logic if you have time, thanks guys
Currently on 0.1.0 Latest: https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/tag/v1.0.1-rc.1
ActiveMQ - "Unable to complete command: unable to create client: unable to create activemq client"
I'm running an ActiveMQ 5.16.0 instance, and I can't make plumber connect to it. The queue is protected by a username and a password. ``` telnet 10.75.93.20 61616 Trying 10.75.93.20......
https://github.com/segmentio/kafka-go/ supports `tls.Config` (see [here](https://github.com/segmentio/kafka-go/blob/9cb6db918c3b84d0f50788c550fa0f7a5706c9b5/dialer_test.go#L164-L168) and [here](https://github.com/segmentio/kafka-go/blob/9cb6db918c3b84d0f50788c550fa0f7a5706c9b5/dialer_test.go#L186-L187) where one can pass in a slice of `tls.Certificate`. I'm not sure how most people would expect to use this in practice, but...
Support for operations on Kafka consumer groups. ``` plumber kafka list-groups plumber kafka delete-group abc plumber kafka create-group bcd ``` Does plumber support mutual TLS?
Adding flags. Follow up commits will update dep from https://github.com/batchcorp/plumber-schemas/pull/77 and update kafka backend.
