What problem does it solve?
Enables Rust applications to reliably send and receive high-throughput event streams to Azure Event Hubs, reducing boilerplate around connection management, batching, partition handling, and checkpointing for distributed consumers.
Core Features & Use Cases
- Producer and Consumer Clients: Builder-pattern clients to create ProducerClient and ConsumerClient for sending and receiving events.
- Batching and Capacity Management: Create and fill batches, check capacity with try_add_event_data, and send efficiently.
- Partitioned Consumption & Checkpointing: Open partition receivers, receive events in parallel, and integrate with a blob checkpoint store for distributed consumer coordination.
- Use Cases: Telemetry ingestion from IoT devices, application logging streams, and real-time analytics pipelines in Rust services.
Quick Start
Create a ProducerClient with DeveloperToolsCredential, send a small batch of events, and validate delivery by reading them with a ConsumerClient.