pulsar-client-go

module
v0.0.0-...-941bdb3 Latest Latest
Warning

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

Go to latest
Published: Nov 13, 2020 License: Apache-2.0

README

pulsar-client-go

迁移说明

该仓库停止更新,转移至https://github.com/tuya/pulsar-client-go

=========

A Go client library for the Apache Pulsar project.

基于Comcastwolfstudy两个项目开发,完全用go实现的pulsar-client

主要优化以下几个点

  1. 修复java-client默认使用batch方式推送消息,go-client接收消息时会出现乱码

  2. 修复failover模式下,在新的consumer加入时,会出现部分消息重复消费的问题

  3. 修复pulsar-broker 进行负载均衡时,会出现topic重启以及broker迁移,此时会导致部分消息重复消费

  4. 优化初始化时内存占用过高的问题

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