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

インターフェース RecordInterceptor<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
すべてのスーパーインターフェース:
ThreadStateProcessor
すべての既知の実装クラス:
CompositeRecordInterceptor
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface RecordInterceptor<K,V> extends ThreadStateProcessor
リスナーを呼び出す前後にリスナーコンテナーによって呼び出される ConsumerRecord のインターセプター。
導入:
2.2.7
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    afterRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    レコードの処理が success(ConsumerRecord, Consumer) または failure(ConsumerRecord, Exception, Consumer) のいずれかで完了したときに呼び出されます。
    default void
    failure(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, ExceptionSE exception, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    リスナーが例外をスローした後に呼び出されます。
    org.apache.kafka.clients.consumer.ConsumerRecord<K,V>
    intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    レコードに対して何らかのアクションを実行するか、別のアクションを返します。
    default void
    success(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    リスナーが正常に終了した後に呼び出されます。

    インターフェース org.springframework.kafka.listener.ThreadStateProcessor から継承されたメソッド

    clearThreadState, setupThreadState

  • メソッドの詳細

    • intercept

      @Nullable org.apache.kafka.clients.consumer.ConsumerRecord<K,V> intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      レコードに対して何らかのアクションを実行するか、別のアクションを返します。null が返された場合、レコードはスキップされます。リスナーの前に呼び出されます。重要 ; このメソッドが別のレコードを返す場合は、望ましくない副作用を回避するために、トピック、パーティション、オフセットを変更しないでください。

      IMPORTANT: トランザクションが使用されており、このメソッドが例外をスローする場合、コンテナーの interceptBeforeTx プロパティが true に設定されている場合は使用できません。

      パラメーター:
      record - レコード。
      consumer - コンシューマー。
      戻り値:
      レコードまたは null。
      導入:
      2.7

    • success

      default void success(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      リスナーが正常に終了した後に呼び出されます。
      パラメーター:
      record - レコード。
      consumer - コンシューマー。
      導入:
      2.7

    • failure

      default void failure(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, ExceptionSE exception, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      リスナーが例外をスローした後に呼び出されます。
      パラメーター:
      record - レコード。
      exception - 例外。
      consumer - コンシューマー。
      導入:
      2.7

    • afterRecord

      default void afterRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      レコードの処理が success(ConsumerRecord, Consumer) または failure(ConsumerRecord, Exception, Consumer) のいずれかで完了したときに呼び出されます。
      パラメーター:
      record - レコード。
      consumer - コンシューマー。
      導入:
      2.8