Apache Pulsar
pulsar-rs: Future-based Rust client forThis is a pure Rust client for Apache Pulsar that does not depend on the C++ Pulsar library. It provides an async/await based API, compatible with Tokio and async-std.
Features:
- URL based (
pulsar://
andpulsar+ssl://
) connections with DNS lookup - multi topic consumers (based on a regex or list)
- TLS connection
- configurable executor (Tokio or async-std)
- automatic reconnection with exponential back off
- message batching
- compression with LZ4, zlib, zstd or Snappy (can be deactivated with Cargo features)
- telemetry using tracing crate (can be activated with Cargo features)
Getting Started
Add the following dependencies in your Cargo.toml
:
futures = "0.3"
pulsar = "5.1"
tokio = "1.0"
Try out examples:
Project Maintainers
Contribution
This project welcomes your PR and issues. For example, refactoring, adding features, correcting English, etc.
Thanks to all the people who already contributed!
License
This library is licensed under the terms of both the MIT license and the Apache License (Version 2.0), and may include packages written by third parties which carry their own copyright notices and license terms.
See LICENSE-APACHE, LICENSE-MIT, and COPYRIGHT for details.