フィールドの詳細

• kafkaTemplate

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

コンストラクターの詳細

• KafkaItemWriter

  public KafkaItemWriter()

メソッドの詳細

• writeKeyValue

  protected void writeKeyValue(K key,
                               T value)

  クラスからコピーされた説明: KeyValueItemWriter
  サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みます

  次で指定:

  クラス KeyValueItemWriter<K, T> の writeKeyValue 

  パラメーター:

  key - キー

  value - アイテム

• flush

  protected void flush()
                throws java.lang.Exception

  クラスからコピーされた説明: KeyValueItemWriter
  アイテムを Key/Value ストアにフラッシュします。

  オーバーライド:

  クラス KeyValueItemWriter<K, T> の flush 

  例外:

  java.lang.Exception - アイテムをフラッシュできない場合

• 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