パッケージ org.springframework.kafka.listener
@NonNullApi パッケージ org.springframework.kafka.listener
kafka リスナーのためのパッケージ
- クラス説明リスナーの
ConsumerSeekAware.ConsumerSeekCallback
を管理します。KafkaBackOffManagerFactory
実装の基本クラス。MessageListenerContainer
の基本実装。受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。未処理のレコード (失敗したレコードを含む) が残っているリスナーコンテナーによって呼び出されます。指定されたバックオフ時間、リスナーコンテナー、例外のハンドラー。受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。BatchInterceptor<K,V> レコードのバッチのインターセプター。バッチ内のどのレコードが失敗したかをフレームワークに通知するために、ユーザーコードによってスローされる例外。BatchMessageListener<K,V> 受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。エラーが発生したときにコンテナーを停止するCommonErrorHandler
。例外の種類に応じて、さまざまなエラーハンドラーに委譲するエラーハンドラー。リスナーコンテナーのエラー処理契約。例外をログに記録するためのCommonErrorHandler
実装。レコードリスナーとバッチリスナーの異なるCommonErrorHandler
に委譲するCommonErrorHandler
。1 つ以上のBatchInterceptor
に順番に委譲するBatchInterceptor
。1 つ以上のRecordInterceptor
に順番に委譲するRecordInterceptor
。concurrency
に基づいて 1 つ以上のKafkaMessageListenerContainer
を作成します。コンシューマーにアクセスできるエラーハンドラー。個々の受信 Kafka メッセージを処理するためのリスナー。コンシューマーオブジェクトへのアクセスを提供するリバランスリスナー。Consumer
への参照の取得をサポートするConsumerRecordRecoverer
。コンシューマーの一時停止 / 再開イベントを発行できるオブジェクト。一般的なコンシューマープロパティ。コンシューマーレコードを回復するためのBiConsumer
SE 拡張。このインターフェースを実装するリスナーには、シーク操作の実行に使用できるConsumerSeekAware.ConsumerSeekCallback
が提供されます。特定のオフセットをシークするためにリスナーが呼び出すことができるコールバック。リスナーコンテナーのグループ。前のグループのすべてのコンテナーがアイドル状態のときに、コンテナーグループの開始をシーケンスします。指定されたタイムスタンプの期限が切れていない場合に、特定のトピックの消費を取り消すマネージャー。バックオフのためにコンテナーを一時停止するBackOffHandler
。リスナーコンテナーのランタイムプロパティが含まれています。オフセットコミット動作の列挙。割り当て中のオフセットコミット動作。厳密に 1 回のセマンティクスのモード。失敗したレコードをデッドレタートピックに公開するConsumerRecordRecoverer
。これを使用して、出力レコードの例外ヘッダーの作成を完全に制御するカスタム実装を提供します。生成されたレコードに追加されるヘッダーの名前のコンテナークラス。DeadLetterPublishingRecoverer.HeaderNames
を作成するための便利な API を提供します。例外ヘッダーのヘッダー名。追加するヘッダーを表すビット。元のレコードプロパティヘッダーのヘッダー名。通常の動作であるヘッダーに追加されるのではなく、このヘッダーが既存のヘッダーをこの名前に置き換える必要があることを示すHeader
。AfterRollbackProcessor
のデフォルト実装。デフォルトBackOffHandler
; バックオフのためにスレッドを一時停止します。レコードリスナーの場合、残りのレコードの各トピックの現在のオフセットを探すエラーハンドラー。このインターフェースを実装するクラスにより、コンテナーは最終的なリスナーの型を決定できます。このインターフェースを実装するコンポーネントは、次の配信試行を提供できます。エラー処理のためのユーティリティ。例外分類をサポートします。バッチを処理(および回復)できるFailedRecordProcessor
のサブクラス。コンシューマーレコードの消費の失敗を処理するクラスの共通スーパークラス。リスナーのトップレベルインターフェース。一般的なメッセージリスナーコンテナー。パラメーターを追加します。backOff が原因でコンシューマーがメッセージをまだ消費していない場合にスローされる例外。KafkaBackOffManagerFactory
インスタンスを作成します。タイムスタンプが未来の場合、指定された dueTimestamp までMessageListenerContainer
をバックオフするためのインターフェース。バックオフに使用される状態を提供します。KafkaException.Level
で構成できるクラスのトップレベルの抽象クラス。@KafkaListener
メソッドが例外をスローしたときに呼び出されるエラーハンドラー。自動パーティション割り当てまたはユーザー構成割り当てをサポートする JavaConsumer
を使用するシングルスレッドメッセージリスナーコンテナー。MessageListenerContainer
の一時停止と再開のためのサービス。リスナーコンテナーのレジストリ。リスナー固有のKafkaException
拡張。KafkaListener
に関連付けられたメタデータ。リスナーの型を定義します。リスナーユーティリティ。成功した場合は DEBUG レベルで、失敗した場合は ERROR のコミット結果をログに記録します。手動 ack をサポートするKafkaListenerErrorHandler
。MessageListener<K,V> 個々の受信 Kafka メッセージを処理するためのリスナー。メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。OffsetAndMetadata
のプロバイダー。RecordInterceptor<K,V> リスナーを呼び出す前後にリスナーコンテナーによって呼び出されるConsumerRecord
のインターセプター。レコードをスキップする必要があるかどうかを判断するために呼び出されます。再試行アクティビティのリスナー。ユーティリティを探します。Consumer
が使用可能な場合に、スレッドにバインドされたリソースを管理するための一般的なインターフェース。スローされたときのタイムスタンプを記録するKafkaException
。