コンストラクターの詳細

• KafkaItemWriterBuilder

  public KafkaItemWriterBuilder()

メソッドの詳細

• kafkaTemplate

  public KafkaItemWriterBuilder<K,V> kafkaTemplate(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)

  KafkaItemWriter が使用する KafkaTemplate を確立します。

  パラメーター:

  kafkaTemplate - 使用するテンプレート

  戻り値:

  メソッド連鎖のためのこのインスタンス

  関連事項:

  KafkaItemWriter.setKafkaTemplate(KafkaTemplate)

• itemKeyMapper

  public KafkaItemWriterBuilder<K,V> itemKeyMapper(org.springframework.core.convert.converter.Converter<V,K> itemKeyMapper)

  アイテムからキーを導出するために使用する Converter を設定します。

  パラメーター:

  itemKeyMapper - 使用するコンバーター。

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  KeyValueItemWriter.setItemKeyMapper(Converter)

• delete

  public KafkaItemWriterBuilder<K,V> delete(boolean delete)

  ライターに渡されるアイテムがすべて削除イベントとしてトピックに送信されるかどうかを示します。削除イベントは、null 値を持つキーで構成されます。false（デフォルト）に設定されている場合、アイテムは itemKeyMapper によって提供された値とキーコンバーターで送信されます。true に設定されている場合、itemKeyMapper の値と null 値からキーコンバーターでアイテムが送信されます。

  パラメーター:

  delete - 取り外しインジケータ。

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  KeyValueItemWriter.setDelete(boolean)

• timeout

  public KafkaItemWriterBuilder<K,V> timeout(long timeout)

  アイテムを Kafka にフラッシュするときに待機する時間制限。

  パラメーター:

  timeout - 待機するミリ秒。デフォルトは -1（タイムアウトなし）です。

  戻り値:

  ビルダーの現在のインスタンス。

  導入:

  4.3.2

  関連事項:

  KafkaItemWriter.setTimeout(long)

• build

  public KafkaItemWriter<K,V> build()

  KafkaItemWriter を検証および構築します。

  戻り値:

  KafkaItemWriter