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
Author:
Tomaz Fernandes, Gary Russell, Soby Chacko, Artem Bilan

  • Method Details

    • create

      DeadLetterPublishingRecoverer create(Function<org.apache.kafka.clients.producer.ProducerRecord<?,?>, ? extends @Nullable KafkaOperations<?,?>> templateResolver, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, Exception, @Nullable 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.