Struct kafka_protocol::records::Record

pub struct Record {
    pub transactional: bool,
    pub control: bool,
    pub partition_leader_epoch: i32,
    pub producer_id: i64,
    pub producer_epoch: i16,
    pub timestamp_type: TimestampType,
    pub offset: i64,
    pub sequence: i32,
    pub timestamp: i64,
    pub key: Option<Bytes>,
    pub value: Option<Bytes>,
    pub headers: IndexMap<StrBytes, Option<Bytes>>,
}

A Kafka message containing key, payload value, and all associated metadata.

Fields

transactional: bool

Whether this record is transactional.

control: bool

Whether this record is a control message, which should not be exposed to the client.

partition_leader_epoch: i32

Epoch of the leader for this record ’s partition.

producer_id: i64

The identifier of the producer.

producer_epoch: i16

Producer metadata used to implement transactional writes.

timestamp_type: TimestampType

Indicates whether timestamp represents record creation or appending to the log.

offset: i64

Message offset within a partition.

sequence: i32

Sequence identifier used for idempotent delivery.

timestamp: i64

Timestamp the record. See also timestamp_type.

key: Option<Bytes>

The key of the record.

value: Option<Bytes>

The payload of the record.

headers: IndexMap<StrBytes, Option<Bytes>>

Headers associated with the record’s payload.

Trait Implementations

impl Clone for Record

fn clone(&self) -> Record

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Record

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

Formats the value using the given formatter.

impl PartialEq for Record

fn eq(&self, other: &Record) -> 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 Eq for Record

impl StructuralPartialEq for Record