All Classes and Interfaces
Class
Description
Encodes a range of offsets, from an incompletes collection into a BitSet.
Subsystem for polling the broker for messages.
Delegate for
KafkaConsumerCommitter that uses the Kafka Consumer to commit either synchronously or asynchronously
Commit request message
Commit response message, linked to a
ConsumerOffsetCommitter.CommitRequestUseful identifier for a
ConsumerRecord.Controls a loading factor.
For tagging polled records with our epoch
This exception is only used when there is an exception thrown from code provided by the user.
Overrides key aspects required in common for other threading engines like Vert.x and Reactor
Generic internal runtime error
Simple identifier tuple for Topic Partitions
Loop implementations that will resume from a given key.
Deserialisation tools for
BitSetEncoder.Base OffsetEncoder
Uses multiple encodings to compare, when decided, can refactor other options out for analysis only -
OffsetMapCodecManager.encodeOffsetsCompressed(long, io.confluent.parallelconsumer.state.PartitionState<K, V>)Decoding result for encoded offsets
Encode with multiple strategies at the same time.
Asynchronous / concurrent message consumer for Kafka.
A simple tuple structure.
Generic Parallel Consumer
RuntimeException parent.Generic Parallel Consumer parent exception.
The options for the
AbstractParallelEoSStreamProcessor system.The type of commit to be made, with either a transactions configured Producer where messages produced are
committed back to the Broker along with the offsets they originated from, or with the faster simpler Consumer
offset system either synchronously or asynchronously
The ordering guarantee to use.
Parallel message consumer which also can optionally produce 0 or many
ProducerRecord results to be published
back to Kafka.A simple triple structure to capture the set of coinciding data.
In charge of managing
PartitionStates.Context object used to pass messages to process to users processing functions.
Internal only view on the
PollContext.Models the queue of work to be processed, based on the
ParallelConsumerOptions.ProcessingOrder modes.https://stackoverflow.com/a/16570509/105741
Context information for the wrapped
ConsumerRecord.Internal only view of the
RecordContext class.No op version of
PartitionState used for when partition assignments are removed, to avoid managing null
references or Optionals.RunLength encoder that leverages the nature of this system.
Simple value class for processing
ShardKeys to make the various key systems type safe and extendable.Shards are local queues of work to be processed.
The run state of the controller.
Single entry point for wrapping the actual execution of user functions
Sharded, prioritised, offset managed, order controlled, delayed work queue.