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

インターフェース BatchToRecordAdapter.Callback<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
含まれているインターフェース:
BatchToRecordAdapter<K,V>
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public static interface BatchToRecordAdapter.Callback<K,V>
各メッセージのコールバック。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message)
    各メッセージを処理します。

  • メソッドの詳細

    • invoke

      void invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Message<?> message)
      各メッセージを処理します。
      パラメーター:
      record - レコード。
      ack - 承認。
      consumer - コンシューマー。
      message - メッセージ。