Struct kafka_protocol::messages::consumer_group_heartbeat_request::ConsumerGroupHeartbeatRequestBuilder

pub struct ConsumerGroupHeartbeatRequestBuilder { /* private fields */ }

Builder for ConsumerGroupHeartbeatRequest.

Implementations

impl ConsumerGroupHeartbeatRequestBuilder

pub fn group_id(&mut self, value: GroupId) -> &mut Self

The group identifier.

Supported API versions: 0

pub fn member_id(&mut self, value: StrBytes) -> &mut Self

The member id generated by the coordinator. The member id must be kept during the entire lifetime of the member.

Supported API versions: 0

pub fn member_epoch(&mut self, value: i32) -> &mut Self

The current member epoch; 0 to join the group; -1 to leave the group; -2 to indicate that the static member will rejoin.

Supported API versions: 0

pub fn instance_id(&mut self, value: Option<StrBytes>) -> &mut Self

null if not provided or if it didn’t change since the last heartbeat; the instance Id otherwise.

Supported API versions: 0

pub fn rack_id(&mut self, value: Option<StrBytes>) -> &mut Self

null if not provided or if it didn’t change since the last heartbeat; the rack ID of consumer otherwise.

Supported API versions: 0

pub fn rebalance_timeout_ms(&mut self, value: i32) -> &mut Self

-1 if it didn’t change since the last heartbeat; the maximum time in milliseconds that the coordinator will wait on the member to revoke its partitions otherwise.

Supported API versions: 0

pub fn subscribed_topic_names( &mut self, value: Option<Vec<TopicName>>, ) -> &mut Self

null if it didn’t change since the last heartbeat; the subscribed topic names otherwise.

Supported API versions: 0

pub fn server_assignor(&mut self, value: Option<StrBytes>) -> &mut Self

null if not used or if it didn’t change since the last heartbeat; the server side assignor to use otherwise.

Supported API versions: 0

pub fn topic_partitions( &mut self, value: Option<Vec<TopicPartitions>>, ) -> &mut Self

null if it didn’t change since the last heartbeat; the partitions owned by the member.

Supported API versions: 0

pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes>, ) -> &mut Self

Other tagged fields

pub fn build( &self, ) -> Result<ConsumerGroupHeartbeatRequest, ConsumerGroupHeartbeatRequestBuilderError>

Builds a new ConsumerGroupHeartbeatRequest.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for ConsumerGroupHeartbeatRequestBuilder

fn clone(&self) -> ConsumerGroupHeartbeatRequestBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for ConsumerGroupHeartbeatRequestBuilder

fn default() -> Self

Returns the “default value” for a type.