インターフェース GenericMessageListener<T>
- 型パラメーター:
T
- リスナーが受信した型。
- すべての既知のサブインターフェース:
AcknowledgingConsumerAwareMessageListener<K,
、V> AcknowledgingMessageListener<K,
、V> BatchAcknowledgingConsumerAwareMessageListener<K,
、V> BatchAcknowledgingMessageListener<K,
、V> BatchConsumerAwareMessageListener<K,
、V> BatchMessageListener<K,
、V> ConsumerAwareMessageListener<K,
、V> MessageListener<K,
V>
- すべての既知の実装クラス:
AggregatingReplyingKafkaTemplate
、BatchMessagingMessageListenerAdapter
、ConvertingMessageListener
、FilteringBatchMessageListenerAdapter
、FilteringMessageListenerAdapter
、KafkaBackoffAwareMessageListenerAdapter
、RecordMessagingMessageListenerAdapter
、ReplyingKafkaTemplate
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
リスナーのトップレベルインターフェース。
- 導入:
- 1.1
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明void
kafka からのデータで呼び出されます。default void
kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。default void
onMessage
(T data, Acknowledgment acknowledgment) kafka からのデータで呼び出されます。default void
onMessage
(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。
メソッドの詳細
onMessage
kafka からのデータで呼び出されます。- パラメーター:
data
- 処理されるデータ。
onMessage
kafka からのデータで呼び出されます。デフォルトの実装はUnsupportedOperationException
SE をスローします。- パラメーター:
data
- 処理されるデータ。acknowledgment
- 承認。
onMessage
kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- パラメーター:
data
- 処理されるデータ。consumer
- コンシューマー。- 導入:
- 2.0
onMessage
default void onMessage(T data, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- パラメーター:
data
- 処理されるデータ。acknowledgment
- 承認。consumer
- コンシューマー。- 導入:
- 2.0