Struct Consumer 

pub struct Consumer { /* private fields */ }

Consumer represents a message consumer that subscribes to a topic and receives messages. It handles communication with the message broker and manages the consumer’s state.

Implementations

impl Consumer

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

Initializes the subscription to a non-partitioned or partitioned topic and starts the health check service.

This function establishes a gRPC connection with the brokers and requests to subscribe to the specified topic.

Errors

If an error occurs during subscription or initialization, it is returned as part of the Err variant.

pub async fn receive(&mut self) -> Result<Receiver<StreamMessage>>

Starts receiving messages from the subscribed partitioned or non-partitioned topic.

This function continuously polls for new messages and handles them as long as the stop_signal has not been set to true.

Returns

A Result with:

• Ok(mpsc::Receiver<StreamMessage>) if the receive client is successfully created and ready to receive messages.
• Err(e) if the receive client cannot be created or if other issues occur.

pub async fn ack(&mut self, message: &StreamMessage) -> Result<()>

pub async fn close(&mut self)

Gracefully close all receive tasks and stop background activities for this consumer

Trait Implementations

impl Debug for Consumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.