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

クラス RecoveringProductionExceptionHandler

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

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

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

    org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse, org.apache.kafka.streams.errors.ProductionExceptionHandler.Response, org.apache.kafka.streams.errors.ProductionExceptionHandler.Result, org.apache.kafka.streams.errors.ProductionExceptionHandler.SerializationExceptionOrigin

  • フィールド概要

    フィールド
    修飾子と型
    フィールド
    説明
    static final StringSE
    DLQ_DESTINATION_RESOLVER
    ネイティブ DLQ 宛先リゾルバーを設定するためのプロパティ名。
    static final StringSE
    RECOVERER
    プロパティを使用して回復者を構成するためのプロパティ名。

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

    deadLetterRecordManager, deadLetterTopic, destinationResolver, recoverer

  • コンストラクター概要

    コンストラクター
    コンストラクター
    説明
    RecoveringProductionExceptionHandler()

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    configure(MapSE<StringSE,?> configs)
    protected org.apache.kafka.streams.errors.ProductionExceptionHandler.Response
    fail()
    処理が失敗することを示すレスポンスを作成します。
    org.apache.kafka.streams.errors.ProductionExceptionHandler.Response
    handleError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> record, ExceptionSE exception)
    org.apache.kafka.streams.errors.ProductionExceptionHandler.Response
    handleSerializationError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.producer.ProducerRecord record, ExceptionSE exception, org.apache.kafka.streams.errors.ProductionExceptionHandler.SerializationExceptionOrigin origin)
    protected org.apache.kafka.streams.errors.ProductionExceptionHandler.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.ProductionExceptionHandler から継承されたメソッド

    handle, handle, handleSerializationException, handleSerializationException

  • フィールドの詳細

    • RECOVERER

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

    • DLQ_DESTINATION_RESOLVER

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

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

    • RecoveringProductionExceptionHandler

      public RecoveringProductionExceptionHandler()

  • 方法の詳細

    • handleError

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

    • handleSerializationError

      public org.apache.kafka.streams.errors.ProductionExceptionHandler.Response handleSerializationError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.producer.ProducerRecord record, ExceptionSE exception, org.apache.kafka.streams.errors.ProductionExceptionHandler.SerializationExceptionOrigin origin)
      次で指定:
      インターフェース org.apache.kafka.streams.errors.ProductionExceptionHandler の handleSerializationError 

    • configure

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

    • fail

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

    • resume

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