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

インターフェース ConsumerAwareRecordRecoverer

すべてのスーパーインターフェース:
BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE>, ConsumerRecordRecoverer
すべての既知の実装クラス:
DeadLetterPublishingRecoverer
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface ConsumerAwareRecordRecoverer extends ConsumerRecordRecoverer
Consumer への参照の取得をサポートする ConsumerRecordRecoverer。
導入:
2.7
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE exception)
    void
    accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, ExceptionSE exception)
    レコードを回復します。

    インターフェース java.util.function.BiConsumerSE から継承されたメソッド

    andThenSE

  • メソッドの詳細

    • accept

      default void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE exception)
      次で指定:
      インターフェース BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE> の acceptSE 

    • accept

      void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, ExceptionSE exception)
      レコードを回復します。
      パラメーター:
      record - レコード。
      consumer - コンシューマー。
      exception - 例外。
      導入:
      2.7