Initialize Pulsar Go client

To interact with Pulsar, you need a Client object first.

You can create a client object using the NewClient function, passing in a ClientOptions object.

Here’s an example:

  1. import (
  2.     "log"
  3.     "time"
  5.     "github.com/apache/pulsar-client-go/pulsar"
  6. )
  8. func main() {
  9.     client, err := pulsar.NewClient(pulsar.ClientOptions{
  10.         URL:               "pulsar://localhost:6650",
  11.         OperationTimeout:  30 * time.Second,
  12.         ConnectionTimeout: 30 * time.Second,
  13.     })
  14.     if err != nil {
  15.         log.Fatalf("Could not instantiate Pulsar client: %v", err)
  16.     }
  18.     defer client.Close()
  19. }

If you have multiple brokers, you can initiate a client object as below.

  1. import (
  2.     "log"
  3.     "time"
  4.     "github.com/apache/pulsar-client-go/pulsar"
  5. )
  7. func main() {
  8.     client, err := pulsar.NewClient(pulsar.ClientOptions{
  9.         URL: "pulsar://localhost:6650,localhost:6651,localhost:6652",
  10.         OperationTimeout:  30 * time.Second,
  11.         ConnectionTimeout: 30 * time.Second,
  12.     })
  13.     if err != nil {
  14.         log.Fatalf("Could not instantiate Pulsar client: %v", err)
  15.     }
  17.     defer client.Close()
  18. }

For all configurable parameters, see ClientOptions.