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

クラス DefaultBatchToRecordAdapter<K,V>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.DefaultBatchToRecordAdapter<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
BatchToRecordAdapter<K,V>
public class DefaultBatchToRecordAdapter<K,V> extends ObjectSE implements BatchToRecordAdapter<K,V>
デフォルトの BatchToRecordAdapter 実装。提供されたリカバリが例外をスローした場合、バッチは中止されます。それ以外の場合は、次のレコードが処理されます。
導入:
2.4.2
作成者:
Gary Russell

  • コンストラクターの詳細

    • DefaultBatchToRecordAdapter

      public DefaultBatchToRecordAdapter()
      失敗したレコードを単にログに記録するデフォルトのリカバリを使用してインスタンスを構築します。

    • DefaultBatchToRecordAdapter

      public DefaultBatchToRecordAdapter(ConsumerRecordRecoverer recoverer)
      提供されたリカバリを使用してインスタンスを構築します。
      パラメーター:
      recoverer - 回復者。

  • メソッドの詳細

    • adapt

      public 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)
      インターフェースからコピーされた説明: BatchToRecordAdapter
      リストを調整し、各メッセージのコールバックを呼び出します。
      次で指定:
      インターフェース BatchToRecordAdapter<K,V> の adapt 
      パラメーター:
      messages - メッセージ。
      records - 記録。
      ack - 承認。
      consumer - コンシューマー。
      callback - コールバック。