Struct SendMessagesConfirmationResponse 

pub struct SendMessagesConfirmationResponse {
    pub stream_id: u32,
    pub topic_id: u32,
    pub partition_id: u32,
    pub base_offset: u64,
}

The Apache Iggy producer/consumer escape hatch: same types Topic::iggy_producer/Topic::iggy_consumer/Topic::iggy_consumer_group return, and the stored message a failed publish hands back, re-exported so reaching for them doesn’t need an iggy dependency of your own. Commit confirmation for one partition written by a SendMessages request.

Wire format:

[stream_id:4][topic_id:4][partition_id:4][base_offset:8]

base_offset is the offset assigned to the first message of the batch in that partition. It does not imply uniqueness: retries outside the server’s deduplication coverage may append the batch again. Crash durability depends on the topic’s durability policy, not on the presence of offset information.

Fields

stream_id: u32

topic_id: u32

partition_id: u32

base_offset: u64

Trait Implementations

impl Clone for SendMessagesConfirmationResponse

fn clone(&self) -> SendMessagesConfirmationResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SendMessagesConfirmationResponse

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

Formats the value using the given formatter.

impl Eq for SendMessagesConfirmationResponse

impl PartialEq for SendMessagesConfirmationResponse

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SendMessagesConfirmationResponse

impl WireDecode for SendMessagesConfirmationResponse

fn decode( buf: &[u8], ) -> Result<(SendMessagesConfirmationResponse, usize), WireError>

Decode from buf, consuming exactly the bytes needed. Returns the decoded value and the number of bytes consumed.

fn decode_from(buf: &[u8]) -> Result<Self, WireError>

Convenience: decode from the entire buffer, ignoring trailing bytes.

impl WireEncode for SendMessagesConfirmationResponse

fn encoded_size(&self) -> usize

Return the exact encoded size in bytes.

fn encode(&self, buf: &mut BytesMut)

Write the encoded representation into buf.

fn to_bytes(&self) -> Bytes

Convenience: allocate a new Bytes and encode into it.