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

Packages that use WorkManager

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

Uses of WorkManager in io.confluent.parallelconsumer.internal

Fields in io.confluent.parallelconsumer.internal declared as WorkManager

Modifier and Type	Field	Description
protected final WorkManager<K,V>	AbstractOffsetCommitter.wm
protected final WorkManager<K,V>	AbstractParallelEoSStreamProcessor.wm

Methods in io.confluent.parallelconsumer.internal that return WorkManager

Modifier and Type	Method	Description
WorkManager<K,V>	AbstractParallelEoSStreamProcessor.getWm()

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

Modifier	Constructor	Description
	AbstractOffsetCommitter(ConsumerManager<K,V> consumerMgr, WorkManager<K,V> wm)
	BrokerPollSystem(ConsumerManager<K,V> consumerMgr, WorkManager<K,V> wm, AbstractParallelEoSStreamProcessor<K,V> pc, ParallelConsumerOptions<K,V> options)
	ConsumerOffsetCommitter(ConsumerManager<K,V> newConsumer, WorkManager<K,V> newWorkManager, ParallelConsumerOptions options)
	ProducerManager(org.apache.kafka.clients.producer.Producer<K,V> newProducer, ConsumerManager<K,V> newConsumer, WorkManager<K,V> wm, ParallelConsumerOptions options)

Uses of WorkManager in io.confluent.parallelconsumer.state

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

Modifier	Constructor	Description
	ShardManager(ParallelConsumerOptions options, WorkManager<K,V> wm, Clock clock)