go

README

Overview

This document describes how to produce message to and consume message from a Pulsar cluster using the Go client.

Prerequisites

• Go 1.11 or higher version
• Go client 0.1.1+ (without 0.1.1)

If you have not installed Go, install it according to the installation instruction.

Example

Note

This example shows how to connect to a Pulsar cluster through the OAuth2 authentication plugin. To connect to a Pulsar cluster through the Token authentication plugin, see the implementation of connectByToken.go.

In this example, the Go producer publishes data to the topic-1 in your Pulsar cluster. The consumer receives the message from the topic-1 and acknowledges each received message. The content of each message payload is a combination of hello- and a digital (0-9), such as hello-0).

1. Get the service URLs. For details, see Get Pulsar service URLs.

2. Get the Oauth2 authentication parameters. For details, see Get Oauth2 authentication parameters.

3. Run the Go consumer to receive messages from the topic topic-1.

   ```bash
   go mod tidy
   go build -o consumer sampleConsumer.go
   ./consumer -serviceURL pulsar+ssl://streamnative.cloud:6651 \
          -privateKey /path/to/private/key/file.json\
          -audience urn:sn:pulsar:pulsar-instance-ns:pulsar-instance-name\
          -issuerUrl https://streamnative.cloud\
          -clientId abcdefghigk0123456789
   ```
   
   **Output**:
   
   ```text
   Received message msgId: {{10 17 0 0} <nil> 0xc0000e0160 {13817980335716751128 17136978 0x4cf4080}} -- content: 'hello-7'
   Received message msgId: {{10 18 0 0} <nil> 0xc0000e0160 {13817980335716772128 17157780 0x4cf4080}} -- content: 'hello-8'
   Received message msgId: {{10 19 0 0} <nil> 0xc0000e0160 {13817980335716774128 17160202 0x4cf4080}} -- content: 'hello-9'
   Received message msgId: {{10 20 0 0} <nil> 0xc0000e0160 {13817980335716776128 17162019 0x4cf4080}} -- content: 'hello-0'
   Received message msgId: {{10 21 0 0} <nil> 0xc0000e0160 {13817980335716780128 17165615 0x4cf4080}} -- content: 'hello-1'
   Received message msgId: {{10 22 0 0} <nil> 0xc0000e0160 {13817980335716781128 17167300 0x4cf4080}} -- content: 'hello-2'
   Received message msgId: {{10 23 0 0} <nil> 0xc0000e0160 {13817980335716783128 17169197 0x4cf4080}} -- content: 'hello-3'
   Received message msgId: {{10 24 0 0} <nil> 0xc0000e0160 {13817980335716788128 17174514 0x4cf4080}} -- content: 'hello-4'
   Received message msgId: {{10 25 0 0} <nil> 0xc0000e0160 {13817980335716790128 17176145 0x4cf4080}} -- content: 'hello-5'
   Received message msgId: {{10 26 0 0} <nil> 0xc0000e0160 {13817980335716792128 17177978 0x4cf4080}} -- content: 'hello-6'
   ```
   

4. Run the Go producer to publish messages to the topic topic-1.

   ```bash
   go mod tidy
   go build -o producer sampleProducer.go
   ./producer -serviceURL pulsar+ssl://streamnative.cloud:6651 \
          -privateKey /path/to/private/key/file.json\
          -audience urn:sn:pulsar:pulsar-instance-ns:pulsar-instance-name\
          -issuerUrl https://streamnative.cloud\
          -clientId abcdefghigk0123456789
   ```
   
   **Output**:
   
   ```text
   Published message: {10 20 0 0} 
   Published message: {10 21 0 0} 
   Published message: {10 22 0 0} 
   Published message: {10 23 0 0} 
   Published message: {10 24 0 0} 
   Published message: {10 25 0 0} 
   Published message: {10 26 0 0} 
   Published message: {10 27 0 0} 
   Published message: {10 28 0 0} 
   Published message: {10 29 0 0}
   ```