Struct RecordHeader 

pub struct RecordHeader { /* private fields */ }

A concrete record header consisting of a key-value pair.

In Java, RecordHeader supports lazy deserialization from ByteBuffer. In Rust, we always store the deserialized String key and Option<Vec<u8>> value directly, since there is no equivalent lazy pattern needed.

Corresponds to Java’s org.apache.kafka.common.header.internals.RecordHeader.

Implementations

impl RecordHeader

pub fn new(key: String, value: Option<Vec<u8>>) -> Self

Create a new RecordHeader with the given key and value.

Panics

This method does not panic. The key must be a valid String (Rust’s type system guarantees non-null).

Trait Implementations

impl Clone for RecordHeader

fn clone(&self) -> RecordHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordHeader

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

Formats the value using the given formatter.

impl Display for RecordHeader

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

Formats the value using the given formatter.

impl FromIterator<RecordHeader> for RecordHeaders

fn from_iter<I: IntoIterator<Item = RecordHeader>>(iter: I) -> Self

Creates a value from an iterator.

impl Hash for RecordHeader

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Header for RecordHeader

fn key(&self) -> &str

Returns the key of the header.

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

Returns the value of the header.

impl PartialEq for RecordHeader

fn eq(&self, other: &Self) -> 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 RecordHeader