Struct SubscribeOptions 

pub struct SubscribeOptions {
    pub consumer_group: Option<String>,
    pub prefetch_count: Option<u16>,
    pub ack_mode: AckMode,
    pub from_beginning: bool,
    pub filter: Option<String>,
    pub concurrency: Option<usize>,
}

Options for subscribing to messages

Fields

consumer_group: Option<String>

Consumer group/tag

prefetch_count: Option<u16>

Prefetch count (how many messages to buffer)

ack_mode: AckMode

Acknowledgment mode

from_beginning: bool

Whether to start from the beginning (for Kafka)

filter: Option<String>

Filter expression (for some brokers)

concurrency: Option<usize>

Maximum concurrent handlers

Implementations

impl SubscribeOptions

pub fn with_consumer_group(self, group: impl Into<String>) -> Self

Set the consumer group

pub fn with_prefetch(self, count: u16) -> Self

Set the prefetch count

pub fn with_ack_mode(self, mode: AckMode) -> Self

Set the acknowledgment mode

pub fn from_beginning(self) -> Self

Start from the beginning (Kafka)

pub fn with_concurrency(self, concurrency: usize) -> Self

Set the concurrency level

Trait Implementations

impl Clone for SubscribeOptions

fn clone(&self) -> SubscribeOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscribeOptions

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

Formats the value using the given formatter.

impl Default for SubscribeOptions

fn default() -> SubscribeOptions

Returns the “default value” for a type.