Uses of Class
io.confluent.parallelconsumer.state.PartitionState
Packages that use PartitionState
-
Uses of PartitionState in io.confluent.parallelconsumer.offsets
Methods in io.confluent.parallelconsumer.offsets that return types with arguments of type PartitionStateModifier and TypeMethodDescriptionMap<org.apache.kafka.common.TopicPartition,PartitionState<K, V>> OffsetMapCodecManager.loadPartitionStateForAssignment(Collection<org.apache.kafka.common.TopicPartition> assignment) Load all the previously completed offsets that were not committedMethods in io.confluent.parallelconsumer.offsets with parameters of type PartitionStateModifier and TypeMethodDescriptionOffsetMapCodecManager.makeOffsetMetadataPayload(long baseOffsetForPartition, PartitionState<K, V> state) -
Uses of PartitionState in io.confluent.parallelconsumer.state
Subclasses of PartitionState in io.confluent.parallelconsumer.stateModifier and TypeClassDescriptionclassNo op version ofPartitionStateused for when partition assignments are removed, to avoid managing null references orOptionals.Methods in io.confluent.parallelconsumer.state that return PartitionStateModifier and TypeMethodDescriptionPartitionStateManager.getPartitionState(org.apache.kafka.common.TopicPartition tp) static PartitionStateRemovedPartitionState.getSingleton()