Uses of Class
org.springframework.kafka.listener.DeadLetterPublishingRecoverer
Packages that use DeadLetterPublishingRecoverer
-
Uses of DeadLetterPublishingRecoverer in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return DeadLetterPublishingRecovererModifier 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 aDeadLetterPublishingRecovererusing the supplied properties.Methods in org.springframework.kafka.retrytopic with parameters of type DeadLetterPublishingRecovererModifier and TypeMethodDescriptionprotected DefaultErrorHandlerListenerContainerFactoryConfigurer.createDefaultErrorHandlerInstance(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer) protected CommonErrorHandlerListenerContainerFactoryConfigurer.createErrorHandler(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration) Method parameters in org.springframework.kafka.retrytopic with type arguments of type DeadLetterPublishingRecovererModifier and TypeMethodDescriptionRetryTopicConfigurationSupport.CustomizersConfigurer.customizeDeadLetterPublishingRecoverer(Consumer<DeadLetterPublishingRecoverer> dlprCustomizer) Customize theDeadLetterPublishingRecovererthat will be used to forward the records to the retry topics and DLT.voidDeadLetterPublishingRecovererFactory.setDeadLetterPublishingRecovererCustomizer(Consumer<DeadLetterPublishingRecoverer> customizer) Set a customizer to customize the defaultDeadLetterPublishingRecoverer.