Package io.confluent.parallelconsumer.state
package io.confluent.parallelconsumer.state
-
ClassesClassDescriptionUseful identifier for a
ConsumerRecord.PartitionState<K,V> In charge of managingPartitionStates.ProcessingShard<K,V> Models the queue of work to be processed, based on theParallelConsumerOptions.ProcessingOrdermodes.No op version ofPartitionStateused for when partition assignments are removed, to avoid managing null references orOptionals.Simple value class for processingShardKeys to make the various key systems type safe and extendable.ShardManager<K,V> Shards are local queues of work to be processed.WorkContainer<K,V> WorkManager<K,V> Sharded, prioritised, offset managed, order controlled, delayed work queue.