Type Alias mz_storage_types::sources::kafka::KafkaTimestamp

pub type KafkaTimestamp = Partitioned<RangeBound<i32>, MzOffset>;

A “moment in time” perceivable in Kafka––for each partition, the greatest visible offset.

Aliased Type

struct KafkaTimestamp(/* private fields */);

Trait Implementations

impl SourceTimestamp for KafkaTimestamp

fn encode_row(&self) -> Row

fn decode_row(row: &Row) -> Self