Struct StreamsGroupHeartbeatRequestV0 

pub struct StreamsGroupHeartbeatRequestV0 {

    pub correlation_id: i32,
    pub client_id: Option<String>,
    pub group_id: String,
    pub member_id: String,
    pub member_epoch: i32,
    pub endpoint_information_epoch: i32,
    pub instance_id: Option<String>,
    pub rack_id: Option<String>,
    pub rebalance_timeout_ms: i32,
    pub topology: Option<StreamsGroupHeartbeatTopology>,
    pub active_tasks: Option<Vec<StreamsGroupHeartbeatTask>>,
    pub standby_tasks: Option<Vec<StreamsGroupHeartbeatTask>>,
    pub warmup_tasks: Option<Vec<StreamsGroupHeartbeatTask>>,
    pub process_id: Option<String>,
    pub user_endpoint: Option<StreamsGroupHeartbeatEndpoint>,
    pub client_tags: Option<Vec<StreamsGroupHeartbeatKeyValue>>,
    pub task_offsets: Option<Vec<StreamsGroupHeartbeatTaskOffset>>,
    pub task_end_offsets: Option<Vec<StreamsGroupHeartbeatTaskOffset>>,
    pub shutdown_application: bool,
}

StreamsGroupHeartbeat v0 request.

Fields

correlation_id: i32

client_id: Option<String>

group_id: String

member_id: String

member_epoch: i32

endpoint_information_epoch: i32

instance_id: Option<String>

rack_id: Option<String>

rebalance_timeout_ms: i32

topology: Option<StreamsGroupHeartbeatTopology>

active_tasks: Option<Vec<StreamsGroupHeartbeatTask>>

standby_tasks: Option<Vec<StreamsGroupHeartbeatTask>>

warmup_tasks: Option<Vec<StreamsGroupHeartbeatTask>>

process_id: Option<String>

user_endpoint: Option<StreamsGroupHeartbeatEndpoint>

client_tags: Option<Vec<StreamsGroupHeartbeatKeyValue>>

task_offsets: Option<Vec<StreamsGroupHeartbeatTaskOffset>>

task_end_offsets: Option<Vec<StreamsGroupHeartbeatTaskOffset>>

shutdown_application: bool

Implementations

impl StreamsGroupHeartbeatRequestV0

pub fn encode(&self) -> Result<Vec<u8>>

Encodes the flexible request, including its request header.

Trait Implementations

impl Clone for StreamsGroupHeartbeatRequestV0

fn clone(&self) -> StreamsGroupHeartbeatRequestV0

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamsGroupHeartbeatRequestV0

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

Formats the value using the given formatter.

impl Eq for StreamsGroupHeartbeatRequestV0

impl PartialEq for StreamsGroupHeartbeatRequestV0

fn eq(&self, other: &StreamsGroupHeartbeatRequestV0) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamsGroupHeartbeatRequestV0