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

クラス AbstractRecoveringExceptionHandler<R>

java.lang.ObjectSE
org.springframework.kafka.streams.AbstractRecoveringExceptionHandler<R>
型パラメーター:
R - ハンドラー固有のレスポンス型
既知の直属サブクラス
RecoveringDeserializationExceptionHandler、RecoveringProcessingExceptionHandler、RecoveringProductionExceptionHandler
public abstract class AbstractRecoveringExceptionHandler<R> extends ObjectSE
Kafka Streams 例外ハンドラーを復元するための抽象基底クラス。
導入:
4.1
作成者:
Lo ï c Greffier

  • フィールドの詳細

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

    • AbstractRecoveringExceptionHandler

      protected AbstractRecoveringExceptionHandler()

    • AbstractRecoveringExceptionHandler

      protected AbstractRecoveringExceptionHandler(ConsumerRecordRecoverer recoverer)

  • 方法の詳細

    • handleErrorCommon

      protected R handleErrorCommon(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE exception, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> sourceRecord)
      優先順位付けされた復旧戦略を用いてエラーを処理します。
      1. ネイティブの Kafka Streams DLQ を介して KafkaStreamsDeadLetterDestinationResolver によって解決されたトピックパーティションに転送することにより、ストリームを再開します。
      2. ネイティブの Kafka Streams DLQ を介して errors.dead.letter.queue.topic.name トピックに転送することで、ストリームを再開します。
      3. リカバリロジックとデッドレターレコードの送信を ConsumerRecordRecoverer に委譲します。デッドレターレコードは ConsumerRecordRecoverer によって処理されることが想定されているため、デッドレターレコードなしで処理を再開します。
      4. デッドレターレコードなしでストリームを失敗させる。
      パラメーター:
      context - エラーハンドラーのコンテキスト
      record - プロセッサーが準備した中間記録の型
      exception - 発生した例外
      sourceRecord - サブトポロジーの入力時の非直列化されたソース生レコード
      戻り値:
      a handler-specific response

    • configureCommon

      protected void configureCommon(MapSE<StringSE,?> configs, StringSE destinationResolverKey, StringSE recovererKey, @Nullable StringSE legacyRecovererKey)
      共通属性を設定します。
      パラメーター:
      configs - the configuration map
      destinationResolverKey - the property key for the native DLQ destination resolver
      recovererKey - the property key for the recoverer
      legacyRecovererKey - the legacy property key for the recoverer, used as fallback if recovererKey is not defined

    • fail

      protected abstract R fail()
      処理が失敗することを示すレスポンスを作成します。
      戻り値:
      ハンドラー固有の失敗レスポンス

    • resume

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