Struct SubscriptionOptionsBuilder 

pub struct SubscriptionOptionsBuilder { /* private fields */ }

Fluent builder for SubscriptionOptions: every parameter has a setter, and Self::build checks that the mandatory ones were set.

Implementations

impl SubscriptionOptionsBuilder

pub fn new() -> Self

Creates a builder with every mandatory parameter unset and every other parameter at the value Java passes on the caller’s behalf.

Returns

The new builder.

pub fn set_topics(self, topics: Vec<String>) -> Self

Sets SubscriptionOptions::topics, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• topics - The list of topics to subscribe to

Returns

This builder.

pub fn set_user_data(self, user_data: Option<Vec<u8>>) -> Self

Sets SubscriptionOptions::user_data.

Arguments

• user_data - Nullable user data to include in the subscription

Returns

This builder.

pub fn set_owned_partitions(self, owned_partitions: Vec<TopicPartition>) -> Self

Sets SubscriptionOptions::owned_partitions.

Arguments

• owned_partitions - The partitions currently owned by this consumer

Returns

This builder.

pub fn set_generation_id(self, generation_id: i32) -> Self

Sets SubscriptionOptions::generation_id.

Arguments

• generation_id - The generation ID of the consumer group

Returns

This builder.

pub fn set_rack_id(self, rack_id: Option<String>) -> Self

Sets SubscriptionOptions::rack_id.

Arguments

• rack_id - Optional rack ID for rack-aware assignment

Returns

This builder.

pub fn build(self) -> Result<SubscriptionOptions, Error>

Returns the built options.

Errors

• Error::is_local_illegal_argument_error naming the first mandatory parameter (today only topics) that was not set.

Trait Implementations

impl Debug for SubscriptionOptionsBuilder

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

Formats the value using the given formatter.

impl Default for SubscriptionOptionsBuilder

fn default() -> Self

Returns the “default value” for a type.