Uses of Package
io.confluent.parallelconsumer

Packages that use io.confluent.parallelconsumer

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

Classes in io.confluent.parallelconsumer used by io.confluent.parallelconsumer

Class	Description
JStreamParallelStreamProcessor
ParallelConsumer	Asynchronous / concurrent message consumer for Kafka.
ParallelConsumer.Tuple	A simple tuple structure.
ParallelConsumerException	Generic Parallel Consumer RuntimeException parent.
ParallelConsumerOptions	The options for the AbstractParallelEoSStreamProcessor system.
ParallelConsumerOptions.CommitMode	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
ParallelConsumerOptions.ParallelConsumerOptionsBuilder
ParallelConsumerOptions.ProcessingOrder	The ordering guarantee to use.
ParallelEoSStreamProcessor
ParallelStreamProcessor	Parallel message consumer which also can optionally produce 0 or many ProducerRecord results to be published back to Kafka.
ParallelStreamProcessor.ConsumeProduceResult	A simple triple structure to capture the set of coinciding data.
PollContext	Context object used to pass messages to process to users processing functions.
RecordContext	Context information for the wrapped ConsumerRecord.
RecordContext.RecordContextBuilder
RecordContextInternal	Internal only view of the RecordContext class.

Classes in io.confluent.parallelconsumer used by io.confluent.parallelconsumer.internal

Class	Description
ParallelConsumer	Asynchronous / concurrent message consumer for Kafka.
ParallelConsumer.Tuple	A simple tuple structure.
ParallelConsumerOptions	The options for the AbstractParallelEoSStreamProcessor system.
PollContextInternal	Internal only view on the PollContext.

Classes in io.confluent.parallelconsumer used by io.confluent.parallelconsumer.state

Class	Description
ParallelConsumerOptions	The options for the AbstractParallelEoSStreamProcessor system.
ParallelConsumerOptions.ProcessingOrder	The ordering guarantee to use.
RecordContext	Context information for the wrapped ConsumerRecord.