Struct ResilientClient 

pub struct ResilientClient { /* private fields */ }

Production-grade resilient client with connection pooling and fault tolerance

Implementations

impl ResilientClient

pub async fn new(config: ResilientClientConfig) -> Result<Self>

Create a new resilient client

pub async fn publish( &self, topic: impl Into<String>, value: impl Into<Bytes>, ) -> Result<u64>

Publish a message to a topic with automatic retries

pub async fn publish_with_key( &self, topic: impl Into<String>, key: Option<impl Into<Bytes>>, value: impl Into<Bytes>, ) -> Result<u64>

Publish a message with a key

pub async fn consume( &self, topic: impl Into<String>, partition: u32, offset: u64, max_messages: usize, ) -> Result<Vec<MessageData>>

Consume messages with automatic retries

pub async fn create_topic( &self, name: impl Into<String>, partitions: Option<u32>, ) -> Result<u32>

Create a topic with automatic retries

pub async fn list_topics(&self) -> Result<Vec<String>>

List all topics

pub async fn delete_topic(&self, name: impl Into<String>) -> Result<()>

Delete a topic

pub async fn commit_offset( &self, consumer_group: impl Into<String>, topic: impl Into<String>, partition: u32, offset: u64, ) -> Result<()>

Commit consumer offset

pub async fn get_offset( &self, consumer_group: impl Into<String>, topic: impl Into<String>, partition: u32, ) -> Result<Option<u64>>

Get consumer offset

pub async fn get_offset_bounds( &self, topic: impl Into<String>, partition: u32, ) -> Result<(u64, u64)>

Get offset bounds (earliest, latest)

pub async fn get_metadata( &self, topic: impl Into<String>, ) -> Result<(String, u32)>

Get topic metadata

pub async fn ping(&self) -> Result<()>

Ping (health check)

pub fn stats(&self) -> ClientStats

Get client statistics