Struct RecordMetadata 

pub struct RecordMetadata { /* private fields */ }

The metadata for a record that has been acknowledged by the server.

Implementations

impl RecordMetadata

pub const UNKNOWN_PARTITION: i32 = -1

Partition value for record without partition assigned.

pub fn new( topic_partition: TopicPartition, base_offset: i64, batch_index: i32, timestamp: i64, serialized_key_size: i32, serialized_value_size: i32, ) -> Self

Creates a new instance with the provided parameters.

Arguments

• topic_partition - the partition
• base_offset - the batch offset
• batch_index - the record’s index
• timestamp - the timestamp
• serialized_key_size - the key size
• serialized_value_size - the value size

pub fn has_offset(&self) -> bool

Indicates whether the record metadata includes the offset.

Returns

true if the offset is included in the metadata, false otherwise.

pub fn offset(&self) -> i64

The offset of the record in the topic/partition. Returns -1 if has_offset() returns false.

Returns

the offset of the record, or -1 if Self::has_offset returns false.

pub fn has_timestamp(&self) -> bool

Indicates whether the record metadata includes the timestamp.

Returns

true if a valid timestamp exists, false otherwise.

pub fn timestamp(&self) -> i64

The timestamp of the record in the topic/partition. Returns -1 if has_timestamp() returns false.

Returns

the timestamp of the record, or -1 if the Self::has_timestamp returns false.

pub fn serialized_key_size(&self) -> i32

Returns the size of the serialized, uncompressed key in bytes. If key is None, the returned size is -1.

pub fn serialized_value_size(&self) -> i32

Returns the size of the serialized, uncompressed value in bytes. If value is None, the returned size is -1.

pub fn topic(&self) -> &str

Returns the topic the record was appended to.

pub fn partition(&self) -> i32

Returns the partition the record was sent to.

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 Display for RecordMetadata

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

Formats the value using the given formatter.