Uses of Interface
org.springframework.kafka.listener.AfterRollbackProcessor
Packages that use AfterRollbackProcessor
Package
Description
Package for kafka configuration
Package for kafka listeners
-
Uses of AfterRollbackProcessor in org.springframework.kafka.config
Methods in org.springframework.kafka.config with parameters of type AfterRollbackProcessorModifier and TypeMethodDescriptionvoid
AbstractKafkaListenerContainerFactory.setAfterRollbackProcessor
(AfterRollbackProcessor<? super K, ? super V> afterRollbackProcessor) Set a processor to invoke after a transaction rollback; typically will seek the unprocessed topic/partition to reprocess the records. -
Uses of AfterRollbackProcessor in org.springframework.kafka.listener
Classes in org.springframework.kafka.listener that implement AfterRollbackProcessorMethods in org.springframework.kafka.listener that return AfterRollbackProcessorModifier and TypeMethodDescriptionAfterRollbackProcessor<? super K,
? super V> AbstractMessageListenerContainer.getAfterRollbackProcessor()
Return the currently configuredAfterRollbackProcessor
.Methods in org.springframework.kafka.listener with parameters of type AfterRollbackProcessorModifier and TypeMethodDescriptionvoid
AbstractMessageListenerContainer.setAfterRollbackProcessor
(AfterRollbackProcessor<? super K, ? super V> afterRollbackProcessor) Set a processor to perform seeks on unprocessed records after a rollback.