Uses of Class
io.confluent.parallelconsumer.PollContext
Packages that use PollContext
-
Uses of PollContext in io.confluent.parallelconsumer
Methods in io.confluent.parallelconsumer that return PollContextModifier and TypeMethodDescriptionParallelStreamProcessor.ConsumeProduceResult.getIn()PollContextInternal.getPollContext()Method parameters in io.confluent.parallelconsumer with type arguments of type PollContextModifier and TypeMethodDescriptionvoidParallelEoSStreamProcessor.poll(Consumer<PollContext<K, V>> usersVoidConsumptionFunction) voidParallelStreamProcessor.poll(Consumer<PollContext<K, V>> usersVoidConsumptionFunction) Register a function to be applied in parallel to each received messagevoidParallelEoSStreamProcessor.pollAndProduce(Function<PollContext<K, V>, org.apache.kafka.clients.producer.ProducerRecord<K, V>> userFunction) voidParallelEoSStreamProcessor.pollAndProduce(Function<PollContext<K, V>, org.apache.kafka.clients.producer.ProducerRecord<K, V>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K, V, K, V>> callback) voidParallelStreamProcessor.pollAndProduce(Function<PollContext<K, V>, org.apache.kafka.clients.producer.ProducerRecord<K, V>> userFunction) Register a function to be applied in parallel to each received message, which in turn returns aProducerRecordto be sent back to the broker.voidParallelStreamProcessor.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 aProducerRecordto be sent back to the broker.voidParallelEoSStreamProcessor.pollAndProduceMany(Function<PollContext<K, V>, List<org.apache.kafka.clients.producer.ProducerRecord<K, V>>> userFunction) voidParallelEoSStreamProcessor.pollAndProduceMany(Function<PollContext<K, V>, List<org.apache.kafka.clients.producer.ProducerRecord<K, V>>> userFunction, Consumer<ParallelStreamProcessor.ConsumeProduceResult<K, V, K, V>> callback) voidParallelStreamProcessor.pollAndProduceMany(Function<PollContext<K, V>, List<org.apache.kafka.clients.producer.ProducerRecord<K, V>>> userFunction) Register a function to be applied in parallel to each received message, which in turn returns one or manyProducerRecords to be sent back to the broker.voidParallelStreamProcessor.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 moreProducerRecords to be sent back to the broker.JStreamParallelEoSStreamProcessor.pollProduceAndStream(Function<PollContext<K, V>, List<org.apache.kafka.clients.producer.ProducerRecord<K, V>>> userFunction) JStreamParallelStreamProcessor.pollProduceAndStream(Function<PollContext<K, V>, List<org.apache.kafka.clients.producer.ProducerRecord<K, V>>> userFunction) LikeAbstractParallelEoSStreamProcessor#pollAndProduceManybut instead of callbacks, streams the results instead, after the produce result is ack'd by Kafka.Constructors in io.confluent.parallelconsumer with parameters of type PollContextModifierConstructorDescriptionConsumeProduceResult(PollContext<K, V> in, org.apache.kafka.clients.producer.ProducerRecord<KK, VV> out, org.apache.kafka.clients.producer.RecordMetadata meta)