Pulsar Go Sample Client

The sample is based on the Pulsar Go client library's reference implmentation.

Set up

Clone the repo under this directory path

~/go/src/github.com/kafkaesque-io

Replace correct pulsar URL, token and topic name in both consumer.go and producer.go files.

Start consumer

$ go run ./src/consumer.go

Start producer

$ go run ./src/producer.go