KafkaStreamsDeadLetterDestinationResolver (Spring for Apache Kafka API) - Javadoc

関数インターフェース:: これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。

@FunctionalInterfaceSE public interface KafkaStreamsDeadLetterDestinationResolver

RecoveringDeserializationExceptionHandler、RecoveringProcessingExceptionHandler、RecoveringProductionExceptionHandler によってネイティブの Kafka Streams DLQ を介して処理された失敗したレコードのデッドレタートピックの宛先を解決するためのインターフェース。

導入:: 4.1
作成者:: Lo ï c Greffier

方法の概要
修飾子と型
メソッド
説明
org.apache.kafka.common.TopicPartition
resolve(org.apache.kafka.streams.errors.ErrorHandlerContext errorHandlerContext, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE exception)
デッドレターレコードの送信先となるトピックパーティションを解決します。

方法の詳細
- resolve
  org.apache.kafka.common.TopicPartition resolve(org.apache.kafka.streams.errors.ErrorHandlerContext errorHandlerContext, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE exception)
  デッドレターレコードの送信先となるトピックパーティションを決定します。パーティション番号に負の値を指定すると、パーティショナーがパーティションを自動的に決定します。
  パラメーター:
  errorHandlerContext - エラーハンドラーのコンテキスト
  record - 故障したプロセッサーの入力レコード
  exception - 例外
  戻り値:
  失敗したレコードを送信するトピックパーティション