Uses of Class
org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Uses of DeadLetterPublishingRecoverer in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionDeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator.create
(Function<org.apache.kafka.clients.producer.ProducerRecord<?, ?>, KafkaOperations<?, ?>> templateResolver, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create aDeadLetterPublishingRecoverer
using the supplied properties.Modifier and TypeMethodDescriptionprotected DefaultErrorHandler
ListenerContainerFactoryConfigurer.createDefaultErrorHandlerInstance
(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer) protected CommonErrorHandler
ListenerContainerFactoryConfigurer.createErrorHandler
(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer) Modifier and TypeMethodDescriptionRetryTopicConfigurationSupport.CustomizersConfigurer.customizeDeadLetterPublishingRecoverer
(Consumer<DeadLetterPublishingRecoverer> dlprCustomizer) Customize theDeadLetterPublishingRecoverer
that will be used to forward the records to the retry topics and DLT.void
DeadLetterPublishingRecovererFactory.setDeadLetterPublishingRecovererCustomizer
(Consumer<DeadLetterPublishingRecoverer> customizer) Set a customizer to customize the defaultDeadLetterPublishingRecoverer
.