パッケージ 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。コンシューマーの一時停止 / 再開イベントを発行できるオブジェクト。一般的なコンシューマープロパティ。コンシューマーレコードを回復するためのBiConsumerSE 拡張。このインターフェースを実装するリスナーには、シーク操作の実行に使用できる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。