Struct FetchResponse 

pub struct FetchResponse {
    pub throttle_time_ms: i32,
    pub error_code: i16,
    pub session_id: i32,
    pub responses: Vec<FetchableTopicResponse>,
    pub node_endpoints: Vec<NodeEndpoint>,
    pub unknown_tagged_fields: UnknownTaggedFields,
}

Fields

throttle_time_ms: i32

error_code: i16

session_id: i32

responses: Vec<FetchableTopicResponse>

node_endpoints: Vec<NodeEndpoint>

unknown_tagged_fields: UnknownTaggedFields

Implementations

impl FetchResponse

pub fn write_plan( &self, version: i16, ) -> Result<Vec<FetchWriteOp>, ProtocolError>

Serialize this response as an ordered FetchWriteOp plan whose concatenated bytes are byte-identical to [FetchResponse::encode] at the same version.

Only valid for the canonical (v4+) Fetch codec — the legacy kafka_3_6_2 path (v0–v3) does not get a plan (it down-converts and stays on the copy path). The caller must gate on version >= 4.

The records length prefix is written into the inline segment that precedes each Records op, so resolving Records to its bytes and concatenating reproduces the exact wire frame.

Trait Implementations

impl Clone for FetchResponse

fn clone(&self) -> FetchResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FetchResponse

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

Formats the value using the given formatter.

impl Decode<'_> for FetchResponse

fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError>

impl Default for FetchResponse

fn default() -> FetchResponse

Returns the “default value” for a type.

impl Encode for FetchResponse

fn encode<B: BufMut>( &self, buf: &mut B, version: i16, ) -> Result<(), ProtocolError>

fn encoded_len(&self, version: i16) -> usize

Size in bytes that encode will write. Must equal the actual count.

impl Eq for FetchResponse

impl From<FetchResponse> for FetchResponse

fn from(c: FetchResponse) -> Self

Converts to this type from the input type.

impl PartialEq for FetchResponse

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for FetchResponse