Struct Consumer 

pub struct Consumer { /* private fields */ }

An initialized live reader with server-managed offsets. A purge restarts the partition at offset 0 without telling an open reader, which can keep its old position and skip the replacement records, so rebuild it after a purge.

Implementations

impl Consumer

pub async fn next(&mut self) -> Option<Result<ConsumerMessage, LaserError>>

Wait for the next record.

pub async fn next_within( &mut self, wait: Duration, ) -> Result<ConsumerMessage, LaserError>

Wait for the next record, bounding how long a caller sits idle: a typed LaserError::Timeout past wait, a typed LaserError::Invalid if the stream ended, or the record itself. One call replaces threading a timeout, a stream-end check, and the per-record decode result through every call site by hand.

let message = consumer.next_within(Duration::from_secs(10)).await?;

pub async fn commit(&self, message: &ConsumerMessage) -> Result<(), LaserError>

Store a handled record’s offset on the server. A policy-aware group consumer stores the contiguous prefix of its partition through this record, so earlier records yielded out of order cannot be skipped.

pub async fn store_offset( &self, offset: u64, partition: Option<u32>, ) -> Result<(), LaserError>

Store an explicit server offset. Native only: a policy-aware group consumer refuses it, because an arbitrary offset bypasses the group’s acknowledgment contract. Commit a delivered record instead.

pub async fn delete_offset( &self, partition: Option<u32>, ) -> Result<(), LaserError>

Delete the server offset for a partition or the current partition. Native only, like store_offset.

pub fn last_consumed_offset(&self, partition: u32) -> Option<u64>

Return the last locally yielded offset for a partition.

pub fn last_stored_offset(&self, partition: u32) -> Option<u64>

Return local offset bookkeeping: the native SDK’s stored offset, whose initial zero does not prove a durable checkpoint exists, or the last offset a policy-aware group consumer acknowledged. Use Next for server-side resume.

pub async fn stored_offset( &self, partition: u32, ) -> Result<Option<StoredOffset>, LaserError>

Read the offset the server stores for this consumer, or for its group, on partition, with the partition’s current head. None when the server stores nothing for it yet. A server read, unlike the local bookkeeping of last_stored_offset.

pub async fn shutdown(&mut self) -> Result<(), LaserError>

Stop polling and leave the group. Automatic policies store the handled prefix first. For group consumers, a clean stop marks the last delivery handled. Native polling commits before delivery, so its shutdown is not a processing checkpoint. CommitPolicy::Disabled preserves the last explicit commit.

Trait Implementations

impl Stream for Consumer

type Item = Result<ConsumerMessage, LaserError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, context: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.