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 网络编程

Download history 5595/week @ 2024-05-03 5127/week @ 2024-05-10 6033/week @ 2024-05-17 3790/week @ 2024-05-24 3380/week @ 2024-05-31 4014/week @ 2024-06-07 3219/week @ 2024-06-14 3029/week @ 2024-06-21 3527/week @ 2024-06-28 3808/week @ 2024-07-05 3431/week @ 2024-07-12 3900/week @ 2024-07-19 3862/week @ 2024-07-26 3141/week @ 2024-08-02 4173/week @ 2024-08-09 4123/week @ 2024-08-16

每月15,872次下载
用于 7 个Crate

MIT/Apache

385KB
9K SLoC

pulsar-rs: 基于Apache Pulsar的基于Future的Rust客户端

crates docs

这是一个纯Rust客户端,用于Apache Pulsar,不依赖于C++ Pulsar库。它提供了一个基于async/await的API,与Tokioasync-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-APACHELICENSE-MITCOPYRIGHT

历史

该项目最初由@stearnsc和其他人在2018年创建于Wyyerd。后来在2022年,原始创建者决定将仓库转移到StreamNative

目前,该项目在StreamNative组织下积极维护,拥有一个多元化的维护者团队

关于StreamNative

StreamNative成立于2019年,由Apache Pulsar的原始创建者成立,是开源Apache Pulsar项目的领先贡献者之一。StreamNative帮助全球的工程团队通过StreamNative Cloud(一个全托管的云服务)迁移到Pulsar,从而加速团队的生产上线时间。

依赖项

~11–32MB
~559K SLoC