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

クラス KafkaItemWriterBuilder<K,V>

java.lang.ObjectSE
org.springframework.batch.item.kafka.builder.KafkaItemWriterBuilder<K,V>
public class KafkaItemWriterBuilder<K,V> extends ObjectSE
KafkaItemWriter のビルダー実装
導入:
4.2
作成者:
Mathieu Ouellet, Mahmoud Ben Hassine

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

    • KafkaItemWriterBuilder

      public KafkaItemWriterBuilder()

  • メソッドの詳細

    • kafkaTemplate

      public KafkaItemWriterBuilder<K,V> kafkaTemplate(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
      KafkaItemWriter が使用する KafkaTemplate を確立します。
      パラメーター:
      kafkaTemplate - 使用するテンプレート
      戻り値:
      メソッド連鎖のためのこのインスタンス
      関連事項:

    • itemKeyMapper

      public KafkaItemWriterBuilder<K,V> itemKeyMapper(org.springframework.core.convert.converter.Converter<V,K> itemKeyMapper)
      アイテムからキーを導出するために使用する Converter を設定します。
      パラメーター:
      itemKeyMapper - 使用するコンバーター。
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • delete

      public KafkaItemWriterBuilder<K,V> delete(boolean delete)
      ライターに渡されるアイテムがすべてトピックへの削除イベントとして送信されるかどうかを示します。削除イベントは、null 値のキーで構成されます。false (デフォルト) に設定すると、アイテムは itemKeyMapper によって提供された値とキーコンバーターとともに送信されます。true に設定すると、アイテムは itemKeyMapper によって値から取得されたキーコンバーターと null 値とともに送信されます。
      パラメーター:
      delete - 取り外しインジケータ。
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • timeout

      public KafkaItemWriterBuilder<K,V> timeout(long timeout)
      アイテムを Kafka にフラッシュするときに待機する時間制限。
      パラメーター:
      timeout - 待機するミリ秒。デフォルトは -1（タイムアウトなし）です。
      戻り値:
      ビルダーの現在のインスタンス。
      導入:
      4.3.2
      関連事項:

    • build

      public KafkaItemWriter<K,V> build()
      KafkaItemWriter を検証および構築します。
      戻り値:
      KafkaItemWriter