Uses of Package
io.confluent.parallelconsumer.state
Packages that use io.confluent.parallelconsumer.state
Package
Description
-
Classes in io.confluent.parallelconsumer.state used by io.confluent.parallelconsumer
-
Classes in io.confluent.parallelconsumer.state used by io.confluent.parallelconsumer.internalClassDescriptionIn charge of managing
PartitionStates.Sharded, prioritised, offset managed, order controlled, delayed work queue. -
Classes in io.confluent.parallelconsumer.state used by io.confluent.parallelconsumer.offsets
-
Classes in io.confluent.parallelconsumer.state used by io.confluent.parallelconsumer.stateClassDescriptionIn charge of managing
PartitionStates.Simple value class for processingShardKeys to make the various key systems type safe and extendable.Shards are local queues of work to be processed.Sharded, prioritised, offset managed, order controlled, delayed work queue.