armada
armada copied to clipboard
Write Pulsar message-receiving client for testing
Using the data defintions and logic in internal/pulsarutils/pulsarclient.go
and messageid.go
, write a basic Pulsar client program that (optionally, authenticates first) to a Pulsar cluster, and continuously polls (select's) from a channel as supplied by the Receive()
func in internal/pulsar/async.go. Connection configuration should be specifiable via command-line flags.
Interrupting the program (ctrl+c / SIGINT) should close the context and terminate the program.
This issue is part of the suite of tools specified in #1460.
Hey team! Please add your planning poker estimate with Zenhub @dejanzele @jayofdoom @kannon92 @richscott @suprjinx