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

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

型パラメーター:
K - 鍵の型。
V - 値の型。
すべての既知の実装クラス:
DefaultBatchToRecordAdapter
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface BatchToRecordAdapter<K,V>
バッチリスナーをレコードリスナーメソッドに適合させるアダプター。たとえば、バッチを単一のトランザクションで処理したいが、各メッセージでリスナーを個別に呼び出したい場合に、これを使用します。
導入:
2.4.2
作成者:
Gary Russell

  • ネストされたクラスのサマリー

    ネストされたクラス
    修飾子と型
    インターフェース
    説明
    static interface
    BatchToRecordAdapter.Callback<K,V>
    各メッセージのコールバック。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    adapt(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, BatchToRecordAdapter.Callback<K,V> callback)
    リストを調整し、各メッセージのコールバックを呼び出します。

  • メソッドの詳細

    • adapt

      void adapt(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, BatchToRecordAdapter.Callback<K,V> callback)
      リストを調整し、各メッセージのコールバックを呼び出します。
      パラメーター:
      messages - メッセージ。
      records - 記録。
      ack - 承認。
      consumer - コンシューマー。
      callback - コールバック。