To set up Go client library in Pulsar, complete the following steps.
You can install the pulsar
library by using either go get
or go module
.
go get
Download the library of Go client to your local environment:
go get -u "github.com/apache/pulsar-client-go/pulsar"
Import it into your project:
import "github.com/apache/pulsar-client-go/pulsar"
go module
Create a directory named test_dir
and change your working directory to it.
mkdir test_dir && cd test_dir
Write a sample script (such as test_example.go
) in the test_dir
directory and write package main
at the beginning of the file.
go mod init test_dir go mod tidy && go mod download go build test_example.go ./test_example
To connect to Pulsar using client libraries, you need to specify a Pulsar protocol URL.
You can assign Pulsar protocol URLs to specific clusters and use the pulsar
scheme. The following is an example of localhost
with the default port 6650
:
pulsar://localhost:6650
If you have multiple brokers, separate IP:port
by commas:
pulsar://localhost:6550,localhost:6651,localhost:6652
If you use mTLS authentication, add +ssl
in the scheme:
pulsar+ssl://pulsar.us-west.example.com:6651