パッケージ org.springframework.kafka.listener.adapter
@NonNullApi パッケージ org.springframework.kafka.listener.adapter
リスナーを適応させるためのクラスを提供します。
- クラス説明すべてのリスナーアダプターの最上位クラス。
RecordFilterStrategyを介してレコードフィルターロジックを実装する抽象メッセージリスナーアダプター。メッセージリスナーアダプターを再試行するための基本クラス。リスナーアダプターのユーティリティ。このインターフェースを実装するメッセージハンドラーアダプターは、HandlerAdapter非同期戻り値の型を検出できます。構成可能なHandlerAdapterを呼び出すMessageListenerアダプター。リスナーがメッセージのバッチを受信するようにファクトリが構成されている場合に使用されます。BatchToRecordAdapter<K,V> バッチリスナーをレコードリスナーメソッドに適合させるアダプター。各メッセージのコールバック。ユーザーがそのようなパラメーターを指定するときに、リスナーメソッドの引数を提供するために使用されます。型Continuationのメソッド引数の何もしないリゾルバー。指定されたMessageConverterを使用して受信したConsumerRecordの変換を実装し、結果を指定されたMessageListenerに渡すAcknowledgingConsumerAwareMessageListenerアダプター。デフォルトのBatchToRecordAdapter実装。提供されたリカバリが例外をスローした場合、バッチは中止されます。それ以外の場合は、次のレコードが処理されます。メッセージペイロード型に基づいてInvocableHandlerMethodに委譲します。RecordFilterStrategyを介してフィルターロジックを実装するBatchMessageListenerアダプター。RecordFilterStrategyを介してフィルターロジックを実装するMessageListenerアダプター。InvocableHandlerMethodまたはDelegatingInvocableHandlerのラッパー。メソッド呼び出しの結果。バックオフ dueTimestamp ヘッダーを検索し、必要に応じてバックオフするKafkaConsumerBackoffManagerインスタンスを呼び出すAcknowledgingConsumerAwareMessageListener実装。Spring Kafka 要件のためのDefaultMessageHandlerMethodFactoryの拡張。Kotlinsuspend機能をサポートするためのInvocableHandlerMethod拡張。Messageのペイロードを抽出するために必要なインフラストラクチャを提供する抽象MessageListenerアダプター。応答式評価のルートオブジェクト。RecordFilterStrategy<K,V> このインターフェースの実装は、メッセージリスナーに配信されようとしているレコードを配信する代わりに破棄する必要があることを通知できます。構成可能なHandlerAdapterを呼び出すMessageListenerアダプター。リスナーが個々のメッセージを受信するようにファクトリが構成されている場合に使用されます。応答メッセージに設定するヘッダーがある場合は、それを構成するための戦略。