Struct ConsumerRecord 

pub struct ConsumerRecord { /* private fields */ }

Record fetched from a Kafka topic partition.

Implementations

impl ConsumerRecord

pub fn topic(&self) -> &str

Returns the Kafka topic name.

pub fn partition(&self) -> i32

Returns the Kafka partition index.

pub fn offset(&self) -> i64

Returns the Kafka record offset.

pub fn leader_epoch(&self) -> i32

Returns the Kafka partition leader epoch attached to this record.

Legacy MessageSet records return -1 because that wire format has no leader epoch field.

pub fn timestamp_ms(&self) -> i64

Returns the Kafka record timestamp in milliseconds since the Unix epoch.

pub fn key(&self) -> Option<&[u8]>

Returns the record key bytes.

pub fn value(&self) -> Option<&[u8]>

Returns the record value bytes.

pub fn headers(&self) -> &[ConsumerRecordHeader]

Returns the headers attached to this record in wire order.

Trait Implementations

impl Clone for ConsumerRecord

fn clone(&self) -> ConsumerRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerRecord

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

Formats the value using the given formatter.

impl Eq for ConsumerRecord

impl PartialEq for ConsumerRecord

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerRecord