Go Client 0.1.0 版本正式发布
由于 Go 语言与生俱来的优势以及 Go 社区的不断壮大,Pulsar 社区对 Go Client 的呼声很高。
详情参考:
https://github.com/apache/pulsar-client-go
新增特性
🙋♂️Client
支持 `TLS` 逻辑。
支持 `Authentication` 逻辑。
支持 `Proxy` 逻辑。
支持 `Hostname verification` 逻辑。
🙋♂️Producer
在 `Producer` 接口中新增以下方法:
`Send()`
`SendAsync()`
`LastSequenceID()`
`Flush()`
`Close()`
`Topic()`
`Name()`
支持 `MessageRouter` 逻辑。
支持 `batch` 逻辑。
支持 `compression message` 逻辑。
支持 `HashingScheme` 逻辑。
支持 `User defined properties producer` 逻辑。
🙋♂️Consumer
在 `Consumer` 接口中新增以下方法:
`Subscription()`
`Unsubscribe()`
`Receive()`
`Ack()`
`AckID()`
`Nack()`
`NackID()`
`Seek()`
`SeekByTime()`
`Close()`
支持 `Dead Letter Queue` 策略。
支持 `Topics Pattern` 和 `Topics` 逻辑。
支持 `topic consumer regx` 逻辑。
支持 `multi topics consumer` 逻辑。
支持 `Exclusive`、`Failover`、`Shared` 和 `KeyShared` 订阅类型逻辑。
支持 `Latest` 和 `Earliest` 逻辑。
支持 `ReadCompacted` 逻辑。
支持 `ReplicateSubscriptionState` 逻辑。
支持 `User defined properties consumer` 逻辑。
支持 `Delayed Delivery Messages` 逻辑。
在 `Reader` 接口中新增以下方法:
`Topic()`
`Next()`
`HasNext()`
`Close()`
支持 `read compacted` 逻辑。
支持 `start messageID` 逻辑。
支持 `User defined properties reader` 逻辑。
未来规划
- 支持 `Schema` 逻辑。
- 支持 `Effectively-Once` 逻辑。
- 支持 `Multi Hosts Service Url support` 逻辑。
贡献
我们非常欢迎并感谢您作出的贡献。关于如何提交补丁和参与项目,可以参考下方链接获取详细信息。
https://github.com/apache/pulsar-client-go/blob/master/CONTRIBUTING.md
贡献者
感谢以下社区人员为 Go Client 0.1.0 版本的正式发布做出卓越贡献:
merlimat
https://github.com/merlimatwolfstudy
https://github.com/wolfstudycckellogg
https://github.com/cckelloggxujianhai666
https://github.com/xujianhai666reugn
https://github.com/reugnfreeznet
https://github.com/freeznetzzzming
https://github.com/zzzmingwty4427300
https://github.com/wty4427300stevenwangnarvar
https://github.com/stevenwangnarvardsmlily
https://github.com/dsmlilybanishee
https://github.com/banisheearchfish
https://github.com/archfishMorsicus
https://github.com/Morsicus
👇🏻点击「阅读原文」查看 Go Client GitHub