Uses of Class
io.confluent.parallelconsumer.state.PartitionState

Packages that use PartitionState

Package	Description
io.confluent.parallelconsumer.offsets
io.confluent.parallelconsumer.state

Uses of PartitionState in io.confluent.parallelconsumer.offsets

Methods in io.confluent.parallelconsumer.offsets that return types with arguments of type PartitionState

Modifier and Type	Method	Description
Map<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 committed

Methods in io.confluent.parallelconsumer.offsets with parameters of type PartitionState

Modifier and Type	Method	Description
String	OffsetMapCodecManager.makeOffsetMetadataPayload(long baseOffsetForPartition, PartitionState<K,V> state)

Uses of PartitionState in io.confluent.parallelconsumer.state

Subclasses of PartitionState in io.confluent.parallelconsumer.state

Modifier and Type	Class	Description
class	RemovedPartitionState<K,V>	No op version of PartitionState used for when partition assignments are removed, to avoid managing null references or Optionals.

Methods in io.confluent.parallelconsumer.state that return PartitionState

Modifier and Type	Method	Description
PartitionState<K,V>	PartitionStateManager.getPartitionState(org.apache.kafka.common.TopicPartition tp)
static PartitionState	RemovedPartitionState.getSingleton()