Package io.confluent.parallelconsumer.offsets
package io.confluent.parallelconsumer.offsets
-
ClassDescriptionEncodes a range of offsets, from an incompletes collection into a BitSet.Deserialisation tools for
BitSetEncoder.Base OffsetEncoderUses multiple encodings to compare, when decided, can refactor other options out for analysis only -OffsetMapCodecManager.encodeOffsetsCompressed(long, io.confluent.parallelconsumer.state.PartitionState<K, V>)Decoding result for encoded offsetsEncode with multiple strategies at the same time.RunLength encoder that leverages the nature of this system.