Struct RecordMetadata 

pub struct RecordMetadata { /* private fields */ }

Metadata returned after a produce operation.

With Acks::None, the request was written and flushed but Kafka does not send a response, so Self::offset is -1 and broker acceptance cannot be confirmed by the client.

Implementations

impl RecordMetadata

pub fn new( topic: impl Into<String>, partition: i32, offset: i64, timestamp: Option<SystemTime>, ) -> Self

Creates metadata for a produced record.

pub fn topic(&self) -> &str

Returns the Kafka topic targeted by the record.

pub fn partition(&self) -> i32

Returns the Kafka partition that accepted the record.

pub fn offset(&self) -> i64

Returns the base offset reported by Kafka.

This is -1 when an idempotent retry receives Kafka’s duplicate sequence response because the original append offset is not available, or when the producer uses Acks::None and Kafka sends no response.

pub fn timestamp(&self) -> Option<SystemTime>

Returns the timestamp associated with the produced record.

Trait Implementations

impl Clone for RecordMetadata

fn clone(&self) -> RecordMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordMetadata

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

Formats the value using the given formatter.

impl Eq for RecordMetadata

impl PartialEq for RecordMetadata

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RecordMetadata