pulsar-client-go 是一个使用 Go 语言编写的 Pulsar Go Client 库,旨在创建纯 Go 语言编写的客户端,并且不依赖任何 C++ 库文件。用户可以通过 Pulsar Go 客户端在 Go(又称 Golang)中创建 Pulsar 生产者、消费者和 reader。在 Go 客户端中,生产者、消费者和 reader 中的所有方法都是线程安全的。
近期, Pulsar Go Client 发布最新 0.7 版本,下面是 0.7 版本关键功能和改进,以供参考。
关键特性
支持生产者加密
支持消费者解密
用户定义度量基数
更好地支持 Azure AD OAuth 2.0
删除 go 版本 1.11 和 1.12 的测试
通过添加 epoch 来创建生产者,避免在 broker 不可用时复制生产者等
改进
修正批大小限制验证问题
修正 sendError 的命令逻辑
在不关闭的情况下,排出请求连接通道
在使用多主题或正则表达式消费者时,不增加 ComsumersOpened 账户
在删除主题时,修正重新连接逻辑
在缩小分区时,避免崩溃
通过现有收集器注册,修复缺少的主题度量
通过 oldProducers ,避免发生器崩溃
在主题终止时,停止消息待处理状态
修复句柄发送错误漏洞问题等