Uses of Class
org.apache.camel.component.kafka.consumer.support.ProcessingResult
Packages that use ProcessingResult
Package
Description
-
Uses of ProcessingResult in org.apache.camel.component.kafka.consumer.errorhandler
Methods in org.apache.camel.component.kafka.consumer.errorhandler with parameters of type ProcessingResultModifier and TypeMethodDescriptionbooleanKafkaConsumerListener.afterProcess(ProcessingResult result) -
Uses of ProcessingResult in org.apache.camel.component.kafka.consumer.support
Methods in org.apache.camel.component.kafka.consumer.support that return ProcessingResultModifier and TypeMethodDescriptionstatic ProcessingResultProcessingResult.newUnprocessed()KafkaRecordProcessor.processExchange(org.apache.camel.Exchange exchange, org.apache.kafka.common.TopicPartition partition, boolean partitionHasNext, boolean recordHasNext, org.apache.kafka.clients.consumer.ConsumerRecord<Object, Object> record, ProcessingResult lastResult, org.apache.camel.spi.ExceptionHandler exceptionHandler) KafkaRecordProcessorFacade.processPolledRecords(org.apache.kafka.clients.consumer.ConsumerRecords<Object, Object> allRecords, ProcessingResult resultFromPreviousPoll) Methods in org.apache.camel.component.kafka.consumer.support with parameters of type ProcessingResultModifier and TypeMethodDescriptionKafkaRecordProcessor.processExchange(org.apache.camel.Exchange exchange, org.apache.kafka.common.TopicPartition partition, boolean partitionHasNext, boolean recordHasNext, org.apache.kafka.clients.consumer.ConsumerRecord<Object, Object> record, ProcessingResult lastResult, org.apache.camel.spi.ExceptionHandler exceptionHandler) KafkaRecordProcessorFacade.processPolledRecords(org.apache.kafka.clients.consumer.ConsumerRecords<Object, Object> allRecords, ProcessingResult resultFromPreviousPoll)