Uses of Class
io.confluent.parallelconsumer.offsets.OffsetSimultaneousEncoder
Packages that use OffsetSimultaneousEncoder
-
Uses of OffsetSimultaneousEncoder in io.confluent.parallelconsumer.offsets
Methods in io.confluent.parallelconsumer.offsets that return OffsetSimultaneousEncoderModifier and TypeMethodDescriptionOffsetSimultaneousEncoder.invoke()Highwater mark already encoded in string -OffsetMapCodecManager.makeOffsetMetadataPayload(long, io.confluent.parallelconsumer.state.PartitionState<K, V>)- so encoding BitSet run length may not be needed, or could be swappedConstructors in io.confluent.parallelconsumer.offsets with parameters of type OffsetSimultaneousEncoderModifierConstructorDescriptionBitSetEncoder(int length, OffsetSimultaneousEncoder offsetSimultaneousEncoder) BitSetEncoder(int length, OffsetSimultaneousEncoder offsetSimultaneousEncoder, OffsetEncoding.Version newVersion) ByteBufferEncoder(int length, OffsetSimultaneousEncoder offsetSimultaneousEncoder) protectedOffsetEncoder(OffsetSimultaneousEncoder offsetSimultaneousEncoder) RunLengthEncoder(OffsetSimultaneousEncoder offsetSimultaneousEncoder, OffsetEncoding.Version newVersion)