cli
This program is a basic CLI utility that can be used to publish and subscribe to a Pulsar topic.
Usage
$ ./cli -h
Usage of ./cli:
-message string
If equal to '--', then STDIN will be used. Otherwise value with %03d $messageNumber tacked on the front will be sent (default "--")
-name string
producer/consumer name (default "demo")
-producer
if true, produce messages, otherwise consume
-pulsar string
pulsar address (default "localhost:6650")
-rate duration
rate at which to send messages (default 1s)
-shared
if true, consumer is shared, otherwise exclusive
-tls-ca string
(optional) path to root certificate
-tls-cert string
(optional) path to TLS certificate
-tls-insecure
if true, do not verify server certificate chain when using TLS
-tls-key string
(optional) path to TLS key
-topic string
producer/consumer topic (default "persistent://sample/standalone/ns1/demo")
Build
$ go build
Basic Examples
These examples connect to a Pulsar server running at localhost:6650
(default) and use the persistent://sample/standalone/ns1/demo
topic (default).
-
Publish message repeatedly
$ ./cli -producer -message "Hello" -rate 1s
-
Publish from STDIN (hit enter after each message)
$ ./cli -producer
-
Subscribe
$ ./cli -shared