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 TypeMethodDescriptioncreate
(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.
-
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 aDeadLetterPublishingRecoverer
using the supplied properties.- Parameters:
templateResolver
- the template resolver.destinationResolver
- the destination resolver.- Returns:
- the publisher.
-