Struct KafkaStreamStats 

pub struct KafkaStreamStats {
    pub messages_consumed: u64,
    pub messages_produced: u64,
    pub consumer_lag: i64,
    pub consume_errors: u64,
    pub produce_errors: u64,
    pub offsets_committed: u64,
    pub commit_errors: u64,
    pub committed_offsets: HashMap<i32, i64>,
}

Statistics for Kafka stream processing

Fields

messages_consumed: u64

Messages consumed from Kafka

messages_produced: u64

Messages produced to Kafka

consumer_lag: i64

Consumer lag (estimated)

consume_errors: u64

Number of consume errors

produce_errors: u64

Number of produce errors

offsets_committed: u64

Number of offsets committed

commit_errors: u64

Number of commit errors

committed_offsets: HashMap<i32, i64>

Last committed offset per partition

Implementations

impl KafkaStreamStats

pub fn new() -> Self

Create new empty stats

pub fn inc_consumed(&mut self)

Increment messages consumed

pub fn inc_produced(&mut self)

Increment messages produced

pub fn inc_consume_errors(&mut self)

Increment consume errors

pub fn inc_produce_errors(&mut self)

Increment produce errors

pub fn inc_offsets_committed(&mut self)

Increment offsets committed

pub fn inc_commit_errors(&mut self)

Increment commit errors

pub fn update_committed_offset(&mut self, partition: i32, offset: i64)

Update committed offset for a partition

Trait Implementations

impl Clone for KafkaStreamStats

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaStreamStats

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

Formats the value using the given formatter.

impl Default for KafkaStreamStats

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for KafkaStreamStats

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for KafkaStreamStats

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.