Struct KafkaContext 

pub struct KafkaContext { /* private fields */ }

Native Kafka delivery metadata, built once per delivery.

Implementations

impl KafkaContext

pub fn topic(&self) -> &str

The topic the record was consumed from.

pub fn partition(&self) -> i32

The partition the record was consumed from.

pub fn offset(&self) -> i64

The record’s offset within its partition.

pub fn timestamp_millis(&self) -> Option<i64>

The record’s timestamp in milliseconds since the epoch, when the broker provided one.

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

The record key, or None for keyless records.

Trait Implementations

impl BuildContext<KafkaMessage> for KafkaContext

fn build(msg: &KafkaMessage) -> Self

Builds the context value by reading fields out of msg.

impl Clone for KafkaContext

fn clone(&self) -> KafkaContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaContext

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

Formats the value using the given formatter.

impl Default for KafkaContext

fn default() -> KafkaContext

Returns the “default value” for a type.

impl Eq for KafkaContext

impl Field<KafkaContext> for Topic

type Value<'a> = &'a str

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> &str

Reads this key’s field out of src.

impl Field<KafkaContext> for Partition

type Value<'a> = i32

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> i32

Reads this key’s field out of src.

impl Field<KafkaContext> for Offset

type Value<'a> = i64

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> i64

Reads this key’s field out of src.

impl Field<KafkaContext> for TimestampMillis

type Value<'a> = Option<i64>

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> Option<i64>

Reads this key’s field out of src.

impl Field<KafkaContext> for Key

type Value<'a> = Option<&'a [u8]>

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> Option<&[u8]>

Reads this key’s field out of src.

impl Field<KafkaContext> for Source

type Value<'a> = SourceOffset

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &KafkaContext) -> SourceOffset

Reads this key’s field out of src.

impl PartialEq for KafkaContext

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for KafkaContext