A Go client library for the Apache Pulsar project.

Developed based on two projects Comcast and wolfstudy, completely using go Implemented pulsar-client.

• Fixed the problem of messy code when go-client receives messages that are pushed by java-client through batch.

• Fixed the problem of repeated consumption of some messages when a new consumer joins in failover mode.

• Fixed the problem of repeated consumption of some messages during topic restart and broker migration, when pulsar-broker executes load balancing.

• Optimized the problem of high memory usage during initialization.

Go 1.11+.

For examples of producers and consumers, see cli.

You can get Tuya developer technical support in the following ways:

• Tuya Help Center
• Tuya technical ticket platform