Package org.springframework.kafka.retrytopic

Interface DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator

Enclosing class:

DeadLetterPublishingRecovererFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator

Implement this interface to create each DeadLetterPublishingRecoverer.

Since:

3.0.9

Method Summary

Modifier and Type	Method	Description
DeadLetterPublishingRecoverer	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 a DeadLetterPublishingRecoverer using the supplied properties.

Method Details

create

DeadLetterPublishingRecoverer 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 a DeadLetterPublishingRecoverer using the supplied properties.

Parameters:

templateResolver - the template resolver.

destinationResolver - the destination resolver.

Returns:

the publisher.