Uses of Class
io.confluent.parallelconsumer.offsets.OffsetMapCodecManager.HighestOffsetAndIncompletes
Packages that use OffsetMapCodecManager.HighestOffsetAndIncompletes
-
Uses of OffsetMapCodecManager.HighestOffsetAndIncompletes in io.confluent.parallelconsumer.offsets
Methods in io.confluent.parallelconsumer.offsets that return OffsetMapCodecManager.HighestOffsetAndIncompletesModifier and TypeMethodDescriptionOffsetMapCodecManager.deserialiseIncompleteOffsetMapFromBase64(long committedOffsetForPartition, String base64EncodedOffsetPayload) EncodedOffsetPair.getDecodedIncompletes(long baseOffset) OffsetMapCodecManager.HighestOffsetAndIncompletes.of()OffsetMapCodecManager.HighestOffsetAndIncompletes.of(long highestSeenOffset) OffsetMapCodecManager.HighestOffsetAndIncompletes.of(long highestSeenOffset, Set<Long> incompleteOffsets) -
Uses of OffsetMapCodecManager.HighestOffsetAndIncompletes in io.confluent.parallelconsumer.state
Constructors in io.confluent.parallelconsumer.state with parameters of type OffsetMapCodecManager.HighestOffsetAndIncompletesModifierConstructorDescriptionPartitionState(org.apache.kafka.common.TopicPartition tp, OffsetMapCodecManager.HighestOffsetAndIncompletes offsetData)