Struct ProducerState 

pub struct ProducerState {
    pub producer_id: u64,
    pub producer_epoch: u16,
    pub partition_sequences: HashMap<(String, u32), i32>,
    pub next_sequence: i32,
}

State for an idempotent/transactional producer

Fields

producer_id: u64

Producer ID assigned by the broker

producer_epoch: u16

Current epoch (increments on reconnect)

partition_sequences: HashMap<(String, u32), i32>

Per-partition sequence numbers for idempotent produce. When the client specifies a partition, the per-partition sequence is used for correct broker-side deduplication. Key: (topic, partition), Value: next sequence number.

next_sequence: i32

Global sequence counter used when the partition is server-assigned (partition=None). The broker tracks this per producer_id.

Implementations

impl ProducerState

pub fn next_sequence_for(&mut self, topic: &str, partition: u32) -> i32

Get the next sequence number for a specific topic-partition, initializing to 1 if this is the first message to that partition.

Trait Implementations

impl Clone for ProducerState

fn clone(&self) -> ProducerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProducerState

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

Formats the value using the given formatter.