Uses of Class
io.confluent.parallelconsumer.ParallelStreamProcessor.ConsumeProduceResult

Packages that use ParallelStreamProcessor.ConsumeProduceResult

Package	Description
io.confluent.parallelconsumer

Uses of ParallelStreamProcessor.ConsumeProduceResult in io.confluent.parallelconsumer

Methods in io.confluent.parallelconsumer that return types with arguments of type ParallelStreamProcessor.ConsumeProduceResult

Modifier and Type	Method	Description
Stream<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>>	JStreamParallelEoSStreamProcessor.pollProduceAndStream(Function<PollContext<K,V>,List<org.apache.kafka.clients.producer.ProducerRecord<K,V>>> userFunction)
Stream<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>>	JStreamParallelStreamProcessor.pollProduceAndStream(Function<PollContext<K,V>,List<org.apache.kafka.clients.producer.ProducerRecord<K,V>>> userFunction)	Like AbstractParallelEoSStreamProcessor#pollAndProduceMany but instead of callbacks, streams the results instead, after the produce result is ack'd by Kafka.

Method parameters in io.confluent.parallelconsumer with type arguments of type ParallelStreamProcessor.ConsumeProduceResult

Modifier and Type	Method	Description
void	ParallelEoSStreamProcessor.pollAndProduce(Function<PollContext<K,V>,org.apache.kafka.clients.producer.ProducerRecord<K,V>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>> callback)
void	ParallelStreamProcessor.pollAndProduce(Function<PollContext<K,V>,org.apache.kafka.clients.producer.ProducerRecord<K,V>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>> callback)	Register a function to be applied in parallel to each received message, which in turn returns a ProducerRecord to be sent back to the broker.
void	ParallelEoSStreamProcessor.pollAndProduceMany(Function<PollContext<K,V>,List<org.apache.kafka.clients.producer.ProducerRecord<K,V>>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>> callback)
void	ParallelStreamProcessor.pollAndProduceMany(Function<PollContext<K,V>,List<org.apache.kafka.clients.producer.ProducerRecord<K,V>>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K,V,K,V>> callback)	Register a function to be applied in parallel to each received message, which in turn returns one or more ProducerRecords to be sent back to the broker.