Package io.confluent.parallelconsumer
package io.confluent.parallelconsumer
-
ClassDescriptionThis exception is only used when there is an exception thrown from code provided by the user.ParallelConsumer<K,
V> Asynchronous / concurrent message consumer for Kafka.A simple tuple structure.Generic Parallel ConsumerRuntimeExceptionparent.The options for theAbstractParallelEoSStreamProcessorsystem.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 asynchronouslyThe ordering guarantee to use.Parallel message consumer which also can optionally produce 0 or manyProducerRecordresults 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 thePollContext.RecordContext<K,V> Context information for the wrappedConsumerRecord.Internal only view of theRecordContextclass.