34个版本 (稳定版)
6.3.0 | 2024年5月17日 |
---|---|
6.1.0 | 2023年10月31日 |
6.0.1 | 2023年6月13日 |
5.1.1 | 2023年4月12日 |
0.1.1 | 2018年10月31日 |
#91 in 网络编程
每月15,872次下载
用于 7 个Crate
385KB
9K SLoC
pulsar-rs: 基于Apache Pulsar的基于Future的Rust客户端
这是一个纯Rust客户端,用于Apache Pulsar,不依赖于C++ Pulsar库。它提供了一个基于async/await的API,与Tokio和async-std兼容。
功能
- 基于URL的(
pulsar://和
pulsar+ssl://
)连接,带有DNS查找; - 多主题消费者(基于正则表达式或列表);
- TLS连接;
- 可配置的执行器(Tokio或async-std);
- 带有指数退避的自动重连;
- 消息批处理;
- 使用LZ4、zlib、zstd或Snappy进行压缩(可以使用Cargo功能禁用);
- 使用tracing crate进行遥测(可以使用Cargo功能启用)。
入门
在您的Cargo.toml
中添加以下依赖项
futures = "0.3"
pulsar = "5.1"
tokio = "1.0"
尝试示例
项目负责人
贡献
本项目欢迎您的PR和问题。例如,重构、添加功能、纠正英语等。
感谢所有已经贡献的人!
许可
本库根据MIT许可证和Apache许可证(版本2.0)的条款进行许可,可能包含由第三方编写的软件包,这些软件包带有自己的版权声明和许可证条款。
有关详细信息,请参阅LICENSE-APACHE、LICENSE-MIT和COPYRIGHT。
历史
该项目最初由@stearnsc和其他人在2018年创建于Wyyerd。后来在2022年,原始创建者决定将仓库转移到StreamNative。
目前,该项目在StreamNative组织下积极维护,拥有一个多元化的维护者团队。
关于StreamNative
StreamNative成立于2019年,由Apache Pulsar的原始创建者成立,是开源Apache Pulsar项目的领先贡献者之一。StreamNative帮助全球的工程团队通过StreamNative Cloud(一个全托管的云服务)迁移到Pulsar,从而加速团队的生产上线时间。
依赖项
~11–32MB
~559K SLoC