Skip to main content

increment_sequence

Function increment_sequence 

Source
pub fn increment_sequence(sequence: i32, increment: i32) -> i32
Expand description

Advance a Kafka producer sequence modulo 2^31.

The result is sequence + increment reduced modulo 2^31. For the nonnegative operands Kafka uses, that is exactly DefaultRecordBatch.incrementSequence: the sum when it fits in an i32, otherwise the sum minus 2^31.