Struct FetchBuilder 

pub struct FetchBuilder<T, C: CodecType> { /* private fields */ }

Builder for fetching messages from a pull consumer.

Implementations

impl<T, C: CodecType> FetchBuilder<T, C>

pub fn max_messages(self, max: usize) -> Self

Set the maximum number of messages to fetch.

pub fn max_bytes(self, max: usize) -> Self

Set the maximum bytes to fetch.

pub fn expires(self, duration: Duration) -> Self

Set the expiration time.

pub fn idle_heartbeat(self, duration: Duration) -> Self

Set the idle heartbeat interval.

impl<T: DeserializeOwned, C: CodecType> FetchBuilder<T, C>

pub async fn fetch(self) -> Result<PullBatch<T, C>>

Execute the fetch.