パッケージ org.springframework.kafka.listener

インターフェース AcknowledgingConsumerAwareMessageListener<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
すべてのスーパーインターフェース:
GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>, MessageListener<K,V>
すべての既知の実装クラス:
ConvertingMessageListener、FilteringMessageListenerAdapter、KafkaBackoffAwareMessageListenerAdapter、RecordMessagingMessageListenerAdapter
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface AcknowledgingConsumerAwareMessageListener<K,V> extends MessageListener<K,V>
受信 Kafka メッセージを処理するためのリスナー。メッセージが処理されたときに受信者が呼び出すことができる確認応答ハンドルを伝播します。Consumer へのアクセスが提供されます。
導入:
2.0
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data)
    kafka からのデータで呼び出されます。
    void
    onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    kafka からのデータで呼び出され、Consumer へのアクセスを提供します。

    インターフェース org.springframework.kafka.listener.GenericMessageListener から継承されたメソッド

    onMessage, onMessage

  • メソッドの詳細

    • onMessage

      default void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data)
      kafka からのデータで呼び出されます。コンテナーはこれを呼び出してはいけません。なぜなら、コンテナーは、コンシューマー認識の確認応答リスナーであることを検出するからです。
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。

    • onMessage

      void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      インターフェースからコピーされた説明: GenericMessageListener
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。
      acknowledgment - 承認。
      consumer - コンシューマー。