インターフェースの使用
org.springframework.kafka.listener.GenericMessageListener
GenericMessageListener を使用するパッケージ
パッケージ
説明
kafka リスナーのためのパッケージ
リスナーを適応させるためのクラスを提供します。
リクエスト / 応答セマンティクスのクラスを提供します。
org.springframework.kafka.listener 内の GenericMessageListener 使用
org.springframework.kafka.listener 内の GenericMessageListener サブインターフェース修飾子と型インターフェース説明interface受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。interface受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。interface受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。interface受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。interface受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。interfaceBatchMessageListener<K,V> 受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。interface個々の受信 Kafka メッセージを処理するためのリスナー。interfaceMessageListener<K,V> 個々の受信 Kafka メッセージを処理するためのリスナー。org.springframework.kafka.listener.adapter 内の GenericMessageListener 使用
修飾子と型クラス説明class構成可能なHandlerAdapterを呼び出すMessageListenerアダプター。リスナーがメッセージのバッチを受信するようにファクトリが構成されている場合に使用されます。class指定されたMessageConverterを使用して受信したConsumerRecordの変換を実装し、結果を指定されたMessageListenerに渡すAcknowledgingConsumerAwareMessageListenerアダプター。classRecordFilterStrategyを介してフィルターロジックを実装するBatchMessageListenerアダプター。classRecordFilterStrategyを介してフィルターロジックを実装するMessageListenerアダプター。classAAcknowledgingConsumerAwareMessageListenerimplementation that looks for a backoff dueTimestamp header and invokes aKafkaConsumerBackoffManagerinstance that will back off if necessary.class構成可能なHandlerAdapterを呼び出すMessageListenerアダプター。リスナーが個々のメッセージを受信するようにファクトリが構成されている場合に使用されます。org.springframework.kafka.requestreply 内の GenericMessageListener 使用
修飾子と型クラス説明class同じ相関 ID を持つ複数の応答を集約する応答テンプレート。classReplyingKafkaTemplate<K,V, R> リクエスト / 応答セマンティクスを実装する KafkaTemplate。