Struct rdkafka::statistics::Partition

pub struct Partition {

    pub partition: i32,
    pub broker: i32,
    pub leader: i32,
    pub desired: bool,
    pub unknown: bool,
    pub msgq_cnt: i64,
    pub msgq_bytes: u64,
    pub xmit_msgq_cnt: i64,
    pub xmit_msgq_bytes: u64,
    pub fetchq_cnt: i64,
    pub fetchq_size: u64,
    pub fetch_state: String,
    pub query_offset: i64,
    pub next_offset: i64,
    pub app_offset: i64,
    pub stored_offset: i64,
    pub committed_offset: i64,
    pub eof_offset: i64,
    pub lo_offset: i64,
    pub hi_offset: i64,
    pub ls_offset: i64,
    pub consumer_lag: i64,
    pub consumer_lag_stored: i64,
    pub txmsgs: u64,
    pub txbytes: u64,
    pub rxmsgs: u64,
    pub rxbytes: u64,
    pub msgs: u64,
    pub rx_ver_drops: u64,
    pub msgs_inflight: i64,
    pub next_ack_seq: i64,
    pub next_err_seq: i64,
    pub acked_msgid: u64,
}

Per-partition statistics.

Fields

partition: i32

The partition ID.

broker: i32

The ID of the broker from which messages are currently being fetched.

leader: i32

The broker ID of the leader.

desired: bool

Whether the partition is explicitly desired by the application.

unknown: bool

Whether the partition is not seen in the topic metadata from the broker.

msgq_cnt: i64

The number of messages waiting to be produced in the first-level queue.

msgq_bytes: u64

The number of bytes waiting to be produced in the first-level queue.

xmit_msgq_cnt: i64

The number of messages ready to be produced in the transmit queue.

xmit_msgq_bytes: u64

The number of bytes ready to be produced in the transmit queue.

fetchq_cnt: i64

The number of prefetched messages in the fetch queue.

fetchq_size: u64

The number of bytes in the fetch queue.

fetch_state: String

The consumer fetch state for this partition (none, stopping, stopped, offset-query, offset-wait, active).

query_offset: i64

The current/last logical offset query.

next_offset: i64

The next offset to fetch.

app_offset: i64

The offset of the last message passed to the application, plus one.

stored_offset: i64

The offset to be committed.

committed_offset: i64

The last committed offset.

eof_offset: i64

The last offset for which partition EOF was signaled.

lo_offset: i64

The low watermark offset on the broker.

hi_offset: i64

The high watermark offset on the broker.

ls_offset: i64

The last stable offset on the broker.

consumer_lag: i64

The difference between hi_offset and committed_offset.

consumer_lag_stored: i64

The difference between hi_offset and stored_offset.

txmsgs: u64

The total number of messages transmitted (produced).

txbytes: u64

The total number of bytes transmitted (produced).

rxmsgs: u64

The total number of messages consumed, not included ignored messages.

rxbytes: u64

The total bytes consumed.

msgs: u64

The total number of messages received, for consumers, or the total number of messages produced, for producers.

rx_ver_drops: u64

The number of dropped outdated messages.

msgs_inflight: i64

The current number of messages in flight to or from the broker.

next_ack_seq: i64

The next expected acked sequence number, for idempotent producers.

next_err_seq: i64

The next expected errored sequence number, for idempotent producers.

acked_msgid: u64

The last acked internal message ID, for idempotent producers.

Trait Implementations

impl Clone for Partition

fn clone(&self) -> Partition

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Partition

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

Formats the value using the given formatter.

impl Default for Partition

fn default() -> Partition

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Partition

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.