Skip to content

Latest commit

 

History

History
22 lines (16 loc) · 466 Bytes

README.md

File metadata and controls

22 lines (16 loc) · 466 Bytes

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