Struct Attributes 

pub struct Attributes(pub i16);

Packed batch-level attributes, encoded as a 16-bit big-endian field in the wire header.

• bits 0-2: compression type (matches CompressionType::as_attribute_bits)
• bit 3: timestamp type (0 = CreateTime, 1 = LogAppendTime)
• bit 4: is_transactional
• bit 5: is_control_batch
• bit 6: has_delete_horizon_ms (Kafka 2.8+; not surfaced separately here)
• bits 7-15: reserved

Tuple Fields

0: i16

Implementations

impl Attributes

pub const TIMESTAMP_TYPE_BIT: i16

pub const TRANSACTIONAL_BIT: i16

pub const CONTROL_BIT: i16

pub fn compression(self) -> CompressionType

pub fn timestamp_type(self) -> TimestampType

pub fn is_transactional(self) -> bool

pub fn is_control_batch(self) -> bool

pub fn with_compression(self, c: CompressionType) -> Self

pub fn with_timestamp_type(self, t: TimestampType) -> Self

pub fn with_transactional(self, b: bool) -> Self

pub fn with_control(self, b: bool) -> Self

Trait Implementations

impl Clone for Attributes

fn clone(&self) -> Attributes

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Attributes

impl Debug for Attributes

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

Formats the value using the given formatter.

impl Default for Attributes

fn default() -> Attributes

Returns the “default value” for a type.

impl Eq for Attributes

impl PartialEq for Attributes

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