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

クラス RecoveringDeserializationExceptionHandler

java.lang.ObjectSE
org.springframework.kafka.streams.AbstractRecoveringExceptionHandler<org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response>
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
実装済みのインターフェース一覧:
org.apache.kafka.common.Configurable, org.apache.kafka.streams.errors.DeserializationExceptionHandler
public class RecoveringDeserializationExceptionHandler extends AbstractRecoveringExceptionHandler<org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response> implements org.apache.kafka.streams.errors.DeserializationExceptionHandler
ConsumerRecordRecoverer を呼び出す、またはネイティブの Kafka ストリーム DLQ を使用する DeserializationExceptionHandler は、DLQ をストリーミングして続行します。
導入:
2.3
作成者:
Gary Russell, Soby Chacko

  • ネストされたクラスの概要

    インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler から継承されたネストクラス / インターフェース

    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse, org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response, org.apache.kafka.streams.errors.DeserializationExceptionHandler.Result

  • フィールド概要

    フィールド
    修飾子と型
    フィールド
    説明
    static final StringSE
    DLQ_DESTINATION_RESOLVER
    ネイティブ DLQ 宛先リゾルバーを設定するためのプロパティ名。
    static final StringSE
    KSTREAM_DESERIALIZATION_RECOVERER
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    4.1 が RECOVERER に有利であるため。
    static final StringSE
    RECOVERER
    プロパティを使用して回復者を構成するためのプロパティ名。

    クラス org.springframework.kafka.streams.AbstractRecoveringExceptionHandler から継承されたフィールド

    deadLetterRecordManager, deadLetterTopic, destinationResolver, recoverer

  • コンストラクター概要

    コンストラクター
    コンストラクター
    説明
    RecoveringDeserializationExceptionHandler()
    RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    configure(MapSE<StringSE,?> configs)
    protected org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response
    fail()
    処理が失敗することを示すレスポンスを作成します。
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
    handle(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    handleError(ErrorHandlerContext, ConsumerRecord, Exception) を推奨する 4.1 以降。
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response
    handleError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)
    protected org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response
    resume(ListSE<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>> deadLetterRecords)
    処理を再開すべきであることを示すレスポンスを作成します。

    クラス org.springframework.kafka.streams.AbstractRecoveringExceptionHandler から継承されたメソッド

    configureCommon, handleErrorCommon

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler から継承されたメソッド

    handle

  • フィールドの詳細

    • KSTREAM_DESERIALIZATION_RECOVERER

      @DeprecatedSE(since="4.1", forRemoval=true) public static final StringSE KSTREAM_DESERIALIZATION_RECOVERER
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      4.1 が RECOVERER に有利であるため。
      プロパティを使用して回復者を構成するためのプロパティ名。
      関連事項:

    • RECOVERER

      public static final StringSE RECOVERER
      プロパティを使用して回復者を構成するためのプロパティ名。
      関連事項:

    • DLQ_DESTINATION_RESOLVER

      public static final StringSE DLQ_DESTINATION_RESOLVER
      ネイティブ DLQ 宛先リゾルバーを設定するためのプロパティ名。
      関連事項:

  • コンストラクターの詳細

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler()

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)

  • 方法の詳細

    • handle

      @DeprecatedSE(since="4.1", forRemoval=true) public org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse handle(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      handleError(ErrorHandlerContext, ConsumerRecord, Exception) を推奨する 4.1 以降。
      構成されたリカバリに委譲することで、デシリアライゼーション例外を処理します。
      次で指定:
      インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler 内の handle 

    • handleError

      public org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response handleError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)
      次で指定:
      インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler 内の handleError 

    • configure

      public void configure(MapSE<StringSE,?> configs)
      次で指定:
      インターフェース org.apache.kafka.common.Configurable 内の configure 

    • fail

      protected org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response fail()
      処理が失敗することを示すレスポンスを作成します。
      次で指定:
      クラス AbstractRecoveringExceptionHandler<org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response> の fail 
      戻り値:
      ハンドラー固有の失敗レスポンス

    • resume

      protected org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response resume(ListSE<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>> deadLetterRecords)
      処理を再開すべきであることを示すレスポンスを作成します。
      次で指定:
      クラス AbstractRecoveringExceptionHandler<org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response> の resume 
      パラメーター:
      deadLetterRecords - DLQ に転送する未配達郵便物記録のリスト
      戻り値:
      担当者固有の履歴書への回答