Module producer 

Idempotent-producer sequence arithmetic and deduplication decision.

Structs

ProducerEntryFacts

The fields of one producer’s tracked entry that the sequence check reads.

RetainedSequenceRange

The sequence range of one batch a producer’s entry retains: Kafka’s BatchMetadata firstSeq and lastSeq.

Enums

ProducerDecision

Result of classifying an idempotent-producer batch.

Functions

decrement_sequence

Move a Kafka producer sequence backwards modulo 2^31.

increment_sequence

Advance a Kafka producer sequence modulo 2^31.

producer_completion_window

Merge a deferred data completion into the current epoch’s retry window.

producer_decision

Classify an incoming batch against a producer’s tracked entry and the sequence ranges of the batches it retains.