Struct ShareConsumerOptions 

pub struct ShareConsumerOptions {
    pub share_acquire_mode: ShareAcquireMode,
    pub max_poll_records: i32,
    pub acknowledgement_commit_callback: Option<AcknowledgementCommitCallback>,
}

Share Consumer Options.

Fields

share_acquire_mode: ShareAcquireMode

Share Acquire Mode.

max_poll_records: i32

Max Poll Records.

acknowledgement_commit_callback: Option<AcknowledgementCommitCallback>

Acknowledgement Commit Callback.

Implementations

impl ShareConsumerOptions

pub fn with_share_acquire_mode( self, share_acquire_mode: ShareAcquireMode, ) -> Self

Sets share acquire mode and returns the updated value.

pub fn with_max_poll_records(self, max_poll_records: i32) -> Self

Sets max poll records and returns the updated value.

pub fn with_acknowledgement_commit_callback<F>(self, callback: F) -> Self

where F: Fn(Vec<ShareAcknowledgementCommit>) + Send + Sync + 'static,

Sets acknowledgement commit callback and returns the updated value.

Trait Implementations

impl Clone for ShareConsumerOptions

fn clone(&self) -> ShareConsumerOptions

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ShareConsumerOptions

fn default() -> Self

Returns the “default value” for a type.