Struct AsyncConsumerBuilder 

pub struct AsyncConsumerBuilder { /* private fields */ }

Builder for constructing an AsyncConsumer asynchronously.

Implementations

impl AsyncConsumerBuilder

pub fn new(hosts: Vec<String>) -> Self

Creates a new async consumer builder from bootstrap hosts.

pub fn with_group(self, group: String) -> Self

Sets the consumer group.

pub fn with_topic(self, topic: String) -> Self

Adds a topic subscription.

pub fn with_topics(self, topics: Vec<String>) -> Self

Adds multiple topic subscriptions.

pub fn with_security(self, security: SecurityConfig) -> Self

Sets optional TLS security configuration for broker connections.

pub fn with_channel_capacity(self, channel_capacity: usize) -> Self

Backward-compatible no-op kept for API compatibility.

pub fn with_native_async(self, native_async: bool) -> Self

Backward-compatible setting kept for API compatibility.

pub fn with_fallback_offset(self, fallback_offset: FetchOffset) -> Self

Sets fallback offset used when there is no committed group offset.

pub fn with_native_retry_attempts(self, attempts: usize) -> Self

Sets retry attempts for native async poll/commit recoverable errors.

pub fn with_native_retry_backoff(self, backoff: Duration) -> Self

Sets retry backoff for native async poll/commit recoverable errors.

pub fn with_native_recent_error_limit(self, limit: usize) -> Self

Sets the max number of native recent error snapshots retained in memory.

pub async fn build(self) -> Result<AsyncConsumer>

Builds an async consumer.