インターフェース AcknowledgingMessageListener<K,V>
- 型パラメーター:
K- 鍵の型。V- 値の型。
- すべてのスーパーインターフェース:
GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,,V>> MessageListener<K,V>
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE
public interface AcknowledgingMessageListener<K,V>
extends MessageListener<K,V>
受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。
- 作成者:
- Marius Bogoevici, Gary Russell
メソッドのサマリー
インターフェース org.springframework.kafka.listener.GenericMessageListener から継承されたメソッド
onMessage, onMessage
メソッドの詳細
onMessage
kafka からのデータで呼び出されます。コンテナーは、承認リスナーであることを検出するため、これを呼び出さないでください。- 次で指定:
- インターフェース
GenericMessageListener<K>のonMessage - パラメーター:
data- 処理されるデータ。
onMessage
void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, @Nullable Acknowledgment acknowledgment) kafka からのデータで呼び出されます。- 次で指定:
- インターフェース
GenericMessageListener<K>のonMessage - パラメーター:
data- 処理されるデータ。acknowledgment- 承認。