パッケージ org.springframework.kafka.streams
@NullMarked パッケージ org.springframework.kafka.streams
Kafka ストリームに関連するクラスのパッケージ。
- クラス説明Kafka Streams 例外ハンドラーを復元するための抽象基底クラス。ヘッダーを操作します。SpEL 評価用のコンテナーオブジェクト。
RecoveringDeserializationExceptionHandler、RecoveringProcessingExceptionHandler、RecoveringProductionExceptionHandlerによってネイティブの Kafka Streams DLQ を介して処理された失敗したレコードのデッドレタートピックの宛先を解決するためのインターフェース。Kafka ストリーム内のインタラクティブクエリストアを囲むラッパー API を提供します。KafkaStreamsのKafkaStreamsMetricsを作成します。ConsumerRecordRecovererを呼び出す、またはネイティブの Kafka ストリーム DLQ を使用するDeserializationExceptionHandlerは、DLQ をストリーミングして続行します。ConsumerRecordRecovererを呼び出す、またはネイティブの Kafka ストリーム DLQ を使用するProcessingExceptionHandlerは、DLQ をストリーミングして続行します。ConsumerRecordRecovererを呼び出す、またはネイティブの Kafka ストリーム DLQ を使用するProductionExceptionHandlerは、DLQ をストリーミングして続行します。