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

Packages that use ShardManager

Package	Description
io.confluent.parallelconsumer.state

Uses of ShardManager in io.confluent.parallelconsumer.state

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

Modifier and Type	Method	Description
ShardManager<K,V>	WorkManager.getSm()

Methods in io.confluent.parallelconsumer.state with parameters of type ShardManager

Modifier and Type	Method	Description
void	PartitionState.onPartitionsRemoved(ShardManager<K,V> sm)

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

Modifier	Constructor	Description
	PartitionStateManager(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, ShardManager<K,V> sm, ParallelConsumerOptions<K,V> options, Clock clock)