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

Packages that use PartitionStateManager

Package	Description
io.confluent.parallelconsumer.internal
io.confluent.parallelconsumer.state

Uses of PartitionStateManager in io.confluent.parallelconsumer.internal

Constructors in io.confluent.parallelconsumer.internal with parameters of type PartitionStateManager

Modifier	Constructor	Description
	EpochAndRecordsMap(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> poll, PartitionStateManager<K,V> pm)

Uses of PartitionStateManager in io.confluent.parallelconsumer.state

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

Modifier and Type	Method	Description
PartitionStateManager<K,V>	WorkManager.getPm()

Constructors in io.confluent.parallelconsumer.state with parameters of type PartitionStateManager

Modifier	Constructor	Description
	ProcessingShard(ShardKey key, ParallelConsumerOptions<?,?> options, PartitionStateManager<K,V> pm)