パッケージ org.springframework.kafka.retrytopic

インターフェース DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator

含まれているクラス:
DeadLetterPublishingRecovererFactory
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public static interface DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator
このインターフェースを実装して、各 DeadLetterPublishingRecoverer を作成します。
導入:
3.0.9

  • メソッドの詳細

    • create

      DeadLetterPublishingRecoverer create(FunctionSE<org.apache.kafka.clients.producer.ProducerRecord<?,?>,KafkaOperations<?,?>> templateResolver, BiFunctionSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE,org.apache.kafka.common.TopicPartition> destinationResolver)
      提供されたプロパティを使用して DeadLetterPublishingRecoverer を作成します。
      パラメーター:
      templateResolver - テンプレートリゾルバー。
      destinationResolver - 宛先リゾルバー。
      戻り値:
      パブリッシャー。