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: