クラスの使用
org.springframework.batch.item.kafka.builder.KafkaItemWriterBuilder
org.springframework.batch.item.kafka.builder 内の KafkaItemWriterBuilder 使用
修飾子と型メソッド説明KafkaItemWriterBuilder.delete
(boolean delete) ライターに渡されるアイテムがすべて削除イベントとしてトピックに送信されるかどうかを示します。KafkaItemWriterBuilder.itemKeyMapper
(org.springframework.core.convert.converter.Converter<V, K> itemKeyMapper) アイテムからキーを導出するために使用するConverter
を設定します。KafkaItemWriterBuilder.kafkaTemplate
(org.springframework.kafka.core.KafkaTemplate<K, V> kafkaTemplate) KafkaItemWriter が使用する KafkaTemplate を確立します。KafkaItemWriterBuilder.timeout
(long timeout) アイテムを Kafka にフラッシュするときに待機する時間制限。