Package io.confluent.parallelconsumer

package io.confluent.parallelconsumer

Related Packages

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

Class	Description
ErrorInUserFunctionException	This exception is only used when there is an exception thrown from code provided by the user.
JStreamParallelEoSStreamProcessor<K,V>
JStreamParallelStreamProcessor<K,V>
ParallelConsumer<K,V>	Asynchronous / concurrent message consumer for Kafka.
ParallelConsumer.Tuple<L,R>	A simple tuple structure.
ParallelConsumerException	Generic Parallel Consumer RuntimeException parent.
ParallelConsumerOptions<K,V>	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<K,V>
ParallelConsumerOptions.ProcessingOrder	The ordering guarantee to use.
ParallelEoSStreamProcessor<K,V>
ParallelStreamProcessor<K,V>	Parallel message consumer which also can optionally produce 0 or many ProducerRecord results to be published back to Kafka.
ParallelStreamProcessor.ConsumeProduceResult<K,V,KK,VV>	A simple triple structure to capture the set of coinciding data.
PollContext<K,V>	Context object used to pass messages to process to users processing functions.
PollContextInternal<K,V>	Internal only view on the PollContext.
RecordContext<K,V>	Context information for the wrapped ConsumerRecord.
RecordContext.RecordContextBuilder<K,V>
RecordContextInternal<K,V>	Internal only view of the RecordContext class.