README
¶
Introduction
A Go client library for the Apache Pulsar project.
Developed based on two projects Comcast and wolfstudy, completely using go Implemented pulsar-client.
Mainly optimize the following points
-
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.
Prepare
Go 1.11+.
Example
For examples of producers and consumers, see cli.
Technical Support
You can get Tuya developer technical support in the following ways:
Directories
¶
| Path | Synopsis |
|---|---|
|
cmd
|
|
|
cli
This program offers a simple CLI utility for interacting with a Pulsar server using the `pulsar` package.
|
This program offers a simple CLI utility for interacting with a Pulsar server using the `pulsar` package. |
|
core
|
|
|
frame
Package frame provides the ability to encode and decode to and from Pulsar's custom binary protocol.
|
Package frame provides the ability to encode and decode to and from Pulsar's custom binary protocol. |
|
pkg
|
|
Click to show internal directories.
Click to hide internal directories.