Uses of Class
io.confluent.parallelconsumer.ParallelConsumer.Tuple

Packages that use ParallelConsumer.Tuple

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

Uses of ParallelConsumer.Tuple in io.confluent.parallelconsumer

Methods in io.confluent.parallelconsumer that return ParallelConsumer.Tuple

Modifier and Type	Method	Description
static <LL, RR> ParallelConsumer.Tuple<LL,RR>	ParallelConsumer.Tuple.pairOf(LL l, RR r)

Uses of ParallelConsumer.Tuple in io.confluent.parallelconsumer.internal

Methods in io.confluent.parallelconsumer.internal that return types with arguments of type ParallelConsumer.Tuple

Modifier and Type	Method	Description
List<ParallelConsumer.Tuple<org.apache.kafka.clients.producer.ProducerRecord<K,V>,Future<org.apache.kafka.clients.producer.RecordMetadata>>>	ProducerManager.produceMessages(List<org.apache.kafka.clients.producer.ProducerRecord<K,V>> outMsgs)	Produce a message back to the broker.
protected <R> List<ParallelConsumer.Tuple<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,R>>	AbstractParallelEoSStreamProcessor.runUserFunction(Function<PollContextInternal<K,V>,List<R>> usersFunction, Consumer<R> callback, List<WorkContainer<K,V>> workContainerBatch)	Run the supplied function.