パッケージ org.springframework.batch.item.kafka

クラス KafkaItemWriter<K,T>

java.lang.ObjectSE
org.springframework.batch.item.KeyValueItemWriter<K,T>
org.springframework.batch.item.kafka.KafkaItemWriter<K,T>
実装されたすべてのインターフェース:
ItemWriter<T>, org.springframework.beans.factory.InitializingBean
public class KafkaItemWriter<K,T> extends KeyValueItemWriter<K,T>

デフォルトのトピックが設定された KafkaTemplate を使用した Apache Kafka の ItemWriter 実装。

このライターはスレッドセーフではありません。

導入:
4.2
作成者:
Mathieu Ouellet, Mahmoud Ben Hassine

  • フィールドの詳細

    • kafkaTemplate

      protected org.springframework.kafka.core.KafkaTemplate<K,T> kafkaTemplate

    • completableFutures

      protected final ListSE<CompletableFutureSE<org.springframework.kafka.support.SendResult<K,T>>> completableFutures

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

    • KafkaItemWriter

      public KafkaItemWriter()

  • メソッドの詳細

    • writeKeyValue

      protected void writeKeyValue(K key, T value)
      クラスからコピーされた説明: KeyValueItemWriter
      サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みます
      次で指定:
      クラス KeyValueItemWriter<K,T> の writeKeyValue 
      パラメーター:
      key - キー
      value - アイテム

    • flush

      protected void flush() throws ExceptionSE
      クラスからコピーされた説明: KeyValueItemWriter
      アイテムを Key/Value ストアにフラッシュします。
      オーバーライド:
      クラス KeyValueItemWriter<K,T> の flush 
      例外:
      ExceptionSE - アイテムをフラッシュできない場合

    • init

      protected void init()
      クラスからコピーされた説明: KeyValueItemWriter
      afterPropertiesSet() フック
      次で指定:
      クラス KeyValueItemWriter<K,T> の init 

    • setKafkaTemplate

      public void setKafkaTemplate(org.springframework.kafka.core.KafkaTemplate<K,T> kafkaTemplate)
      使用する KafkaTemplate を設定します。
      パラメーター:
      kafkaTemplate - 使用対象

    • setTimeout

      public void setTimeout(long timeout)
      アイテムを Kafka にフラッシュするときに待機する時間制限。
      パラメーター:
      timeout - 待機するミリ秒。デフォルトは -1（タイムアウトなし）です。
      導入:
      4.3.2