Trait ConsumerStream 

pub trait ConsumerStream: Stream<Item = Result<ConsumerRecord, ErrorCode>> + Unpin {
    // Required methods
    fn offset_commit(&mut self) -> ConsumerBoxFuture<'_>;
    fn offset_flush(&mut self) -> ConsumerBoxFuture<'_>;
}

Extension of Stream trait with offset management capabilities.

Required Methods

fn offset_commit(&mut self) -> ConsumerBoxFuture<'_>

Mark the offset of the last yelded record as committed. Depending on OffsetManagementStrategy it may require a subsequent offset_flush() call to take any effect.

fn offset_flush(&mut self) -> ConsumerBoxFuture<'_>

Send the committed offset to the server. The method waits for the server’s acknowledgment before it finishes.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl ConsumerStream for Pin<Box<dyn ConsumerStream + Send>>

Available on non-WebAssembly only.

fn offset_commit(&mut self) -> ConsumerBoxFuture<'_>

fn offset_flush(&mut self) -> ConsumerBoxFuture<'_>

Implementors

impl ConsumerStream for ConsumerRetryStream

impl<T: Stream<Item = Result<ConsumerRecord, ErrorCode>> + Unpin> ConsumerStream for MultiplePartitionConsumerStream<T>

impl<T: Stream<Item = Result<ConsumerRecord, ErrorCode>> + Unpin> ConsumerStream for SinglePartitionConsumerStream<T>