Struct RequestHeader 

pub struct RequestHeader {
    pub api_key: i16,
    pub api_version: i16,
    pub correlation_id: i32,
    pub client_id: Option<String>,
}

Kafka request header (api_key through client_id, plus tagged fields when flexible).

std::fmt::Display is Java RequestHeader.toString: RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=client, correlationId=1, headerVersion=2). apiKey is the Kafka 4.0 ApiKeys enum name (not ApiMessageType.name). Null clientId prints null; an empty id prints empty. Self::size is Java RequestHeader.size.

Fields

api_key: i16

Api key.

api_version: i16

Api version.

correlation_id: i32

Correlation id echoed on the response.

client_id: Option<String>

Kafka client.id, or None for a null string.

Implementations

impl RequestHeader

pub const fn api_key(&self) -> i16

Java RequestHeader.apiKey id.

pub const fn api_version(&self) -> i16

Java RequestHeader.apiVersion.

pub const fn correlation_id(&self) -> i32

Java RequestHeader.correlationId.

pub fn client_id(&self) -> Option<&str>

Java RequestHeader.clientId (None is Java null).

pub fn header_version(&self) -> i16

Java RequestHeader.headerVersion.

pub fn size(&self) -> i32

Java RequestHeader.size.

Serialized bytes: INT16 api key, INT16 api version, INT32 correlation id, classic nullable STRING clientId, plus one empty tagged-fields unsigned varint when Self::header_version is 2. Matches encode_request_header.

pub const fn to_response_header(&self) -> ResponseHeader

Java RequestHeader.toResponseHeader.

Copies Self::correlation_id. Java also stores apiKey.responseHeaderVersion(apiVersion) on the result; this crate’s ResponseHeader only has correlationId.

pub fn check_correlation(&self, response: &ResponseHeader) -> Result<()>

Java AbstractResponse.parseResponse correlation-id check (CorrelationIdMismatchException).

Trait Implementations

impl Clone for RequestHeader

fn clone(&self) -> RequestHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestHeader

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

Formats the value using the given formatter.

impl Display for RequestHeader

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

Formats the value using the given formatter.