Struct TransactionMarkerRequest 

pub struct TransactionMarkerRequest {
    pub producer_id: i64,
    pub producer_epoch: i16,
    pub coordinator_epoch: i32,
    pub is_commit: bool,
    pub is_offsets_partition: bool,
}

One transaction marker as it reaches one data partition.

Fields

producer_id: i64

producer_epoch: i16

coordinator_epoch: i32

The sending coordinator’s epoch; -1 names no coordinator generation.

is_commit: bool

The marker is a COMMIT rather than an ABORT.

is_offsets_partition: bool

The partition is a __consumer_offsets partition.

Trait Implementations

impl Clone for TransactionMarkerRequest

fn clone(&self) -> TransactionMarkerRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TransactionMarkerRequest

impl Debug for TransactionMarkerRequest

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

Formats the value using the given formatter.

impl Eq for TransactionMarkerRequest

impl PartialEq for TransactionMarkerRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TransactionMarkerRequest