クラス 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
デフォルトのトピックが設定された KafkaTemplate
を使用した Apache Kafka の ItemWriter
実装。
このライターはスレッドセーフではありません。
- 導入:
- 4.2
- 作成者:
- Mathieu Ouellet, Mahmoud Ben Hassine
フィールドサマリー
修飾子と型フィールド説明protected final ListSE<CompletableFutureSE<org.springframework.kafka.support.SendResult<K,
T>>> クラス org.springframework.batch.item.KeyValueItemWriter から継承されたフィールド
delete, itemKeyMapper
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明protected void
flush()
アイテムを Key/Value ストアにフラッシュします。protected void
init()
afterPropertiesSet() フックvoid
setKafkaTemplate
(org.springframework.kafka.core.KafkaTemplate<K, T> kafkaTemplate) 使用するKafkaTemplate
を設定します。void
setTimeout
(long timeout) アイテムを Kafka にフラッシュするときに待機する時間制限。protected void
writeKeyValue
(K key, T value) サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みますクラス org.springframework.batch.item.KeyValueItemWriter から継承されたメソッド
afterPropertiesSet, setDelete, setItemKeyMapper, write
フィールドの詳細
kafkaTemplate
completableFutures
protected final ListSE<CompletableFutureSE<org.springframework.kafka.support.SendResult<K,T>>> completableFutures
コンストラクターの詳細
KafkaItemWriter
public KafkaItemWriter()
メソッドの詳細
writeKeyValue
クラスからコピーされた説明:KeyValueItemWriter
サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みます- 次で指定:
- クラス
KeyValueItemWriter<K,
のT> writeKeyValue
- パラメーター:
key
- キーvalue
- アイテム
flush
クラスからコピーされた説明:KeyValueItemWriter
アイテムを Key/Value ストアにフラッシュします。- オーバーライド:
- クラス
KeyValueItemWriter<K,
のT> flush
- 例外:
ExceptionSE
- アイテムをフラッシュできない場合
init
protected void init()クラスからコピーされた説明:KeyValueItemWriter
afterPropertiesSet() フック- 次で指定:
- クラス
KeyValueItemWriter<K,
のT> init
setKafkaTemplate
使用するKafkaTemplate
を設定します。- パラメーター:
kafkaTemplate
- 使用対象
setTimeout
public void setTimeout(long timeout) アイテムを Kafka にフラッシュするときに待機する時間制限。- パラメーター:
timeout
- 待機するミリ秒。デフォルトは -1(タイムアウトなし)です。- 導入:
- 4.3.2