Neutron - This package is currently a Work In Progress and is NOT Production Ready
An Apache Pulsar client library, built with pure rust 🦀 and requires no C++ dependencies.
Features:
- Pure Rust, No C++ Dependencies 🦀
- Consumer Client 📥
- Producer Client 📤
- Plugin Support 🔌
- Multi/Dual Consumer & Producer Support 🤝
- TLS Support via rustls 🔐
- Async Resolution of Send & Acks 🪓
- Batching Support 📦
- Automatic Reconnection ♻️
- Automatic Operation Retry 🚀
Installation
Using Cargo Add
This will install the newest version of neutron
into your cargo.toml
Manually
As this is currently in prerelease you must use the git ssh address directly.
= "0.0.2"
Features
The json
feature provides automatic de/serialization through serde_json
.
= { = "0.0.2", = ["json"] }
Example
This is a simple example of a consumer that listens to a topic and prints the message. with the json
feature enabled
use ;
use ;
async