pulsar-client-go

module
v0.0.0-...-2c99a81 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2021 License: Apache-2.0

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.
msg
pub
srv
sub
pkg
api
log

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL