インターフェース KafkaStreamsDeadLetterDestinationResolver
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
RecoveringDeserializationExceptionHandler、RecoveringProcessingExceptionHandler、RecoveringProductionExceptionHandler によってネイティブの Kafka Streams DLQ を介して処理された失敗したレコードのデッドレタートピックの宛先を解決するためのインターフェース。- 導入:
- 4.1
- 作成者:
- Lo ï c Greffier
方法の概要
修飾子と型メソッド説明org.apache.kafka.common.TopicPartitionresolve(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) Resolves the topic-partition to which a dead-letter record should be sent. Use a negative partition number to let the partitioner determine the partition.- パラメーター:
errorHandlerContext- エラーハンドラーのコンテキストrecord- the input record of the failed processorexception- 例外- 戻り値:
- the topic-partition to which the failed record should be sent