インターフェース BatchAcknowledgingConsumerAwareMessageListener<K,V>
- 型パラメーター:
K- 鍵の型。V- 値の型。
- すべてのスーパーインターフェース:
BatchMessageListener<K,,V> GenericMessageListener<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE
public interface BatchAcknowledgingConsumerAwareMessageListener<K,V>
extends BatchMessageListener<K,V>
受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認応答ハンドルを伝播します。リストは、ポーリングによって返されたコンシューマーレコードオブジェクトから作成されます。
Consumer へのアクセスが提供されます。- 導入:
- 2.0
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明default voidkafka からのデータで呼び出されます。voidonMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumerへのアクセスを提供します。インターフェース org.springframework.kafka.listener.BatchMessageListener から継承されたメソッド
onMessage, wantsPollResultインターフェース org.springframework.kafka.listener.GenericMessageListener から継承されたメソッド
onMessage, onMessage
メソッドの詳細
onMessage
Kafka からのデータを使用して呼び出されます。コンテナーはこれを決して呼び出すべきではありません。コンテナーは、コンシューマーを意識した承認リスナーであることを検出してしまうからです。- 次で指定:
- インターフェース
GenericMessageListener<K>のonMessage - パラメーター:
data- 処理されるデータ。
onMessage
void onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) インターフェースからコピーされた説明:GenericMessageListenerkafka からのデータで呼び出され、Consumerへのアクセスを提供します。デフォルトの実装はUnsupportedOperationExceptionSE をスローします。- 次で指定:
- インターフェース
GenericMessageListener<K>のonMessage - パラメーター:
data- 処理されるデータ。acknowledgment- 承認。consumer- コンシューマー。