Skip to main content

decrement_sequence

Function decrement_sequence 

Source
pub fn decrement_sequence(sequence: i32, decrement: i32) -> i32
Expand description

Move a Kafka producer sequence backwards modulo 2^31.

The result is sequence - decrement reduced modulo 2^31. For the nonnegative operands Kafka uses, that is exactly DefaultRecordBatch.decrementSequence: the difference when it is not negative, otherwise the difference plus 2^31.