Struct AsyncConsumer 

pub struct AsyncConsumer { /* private fields */ }

An async Kafka consumer.

Implementations

impl AsyncConsumer

pub fn builder(hosts: Vec<String>) -> AsyncConsumerBuilder

Starts building a new async consumer from bootstrap hosts.

pub async fn from_hosts( hosts: Vec<String>, group: String, topics: Vec<String>, ) -> Result<Self>

Creates a new async consumer from bootstrap hosts.

pub async fn from_client( client: AsyncKafkaClient, group: String, topics: Vec<String>, ) -> Result<Self>

Creates a new async consumer from an AsyncKafkaClient.

pub async fn poll(&mut self) -> Result<MessageSets>

Polls for new messages and returns fetched message sets.

pub async fn commit(&mut self) -> Result<()>

Commits the current consumed offsets.

pub async fn close(self) -> Result<()>

Gracefully closes the consumer.

pub fn native_error_stats(&self) -> Option<NativeConsumerErrorStats>

Returns native consumer error statistics when running in native mode.

pub fn reset_native_error_stats(&mut self) -> bool

Resets native consumer error statistics.

Returns true when reset was performed (native mode), otherwise false.