パッケージ org.springframework.cloud.task.batch.autoconfigure.kafka

クラス KafkaItemWriterAutoConfiguration

java.lang.ObjectSE
org.springframework.cloud.task.batch.autoconfigure.kafka.KafkaItemWriterAutoConfiguration
@AutoConfiguration @EnableConfigurationProperties({org.springframework.boot.autoconfigure.kafka.KafkaProperties.class,KafkaItemWriterProperties.class}) @AutoConfigureAfter(org.springframework.boot.autoconfigure.batch.BatchAutoConfiguration.class) public class KafkaItemWriterAutoConfiguration extends ObjectSE
KafkaItemReader の自動構成。
導入:
2.3
作成者:
Glenn Renfro, Michael Minella

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

    • KafkaItemWriterAutoConfiguration

      public KafkaItemWriterAutoConfiguration()

  • メソッドの詳細

    • kafkaItemWriter

      @Bean @ConditionalOnMissingBean @ConditionalOnProperty(prefix="spring.batch.job.kafkaitemwriter", name="topic") public org.springframework.batch.item.kafka.KafkaItemWriter<ObjectSE,MapSE<StringSE,ObjectSE>> kafkaItemWriter(KafkaItemWriterProperties kafkaItemWriterProperties, org.springframework.kafka.core.ProducerFactory<ObjectSE,MapSE<StringSE,ObjectSE>> producerFactory, @Qualifier("batchItemKeyMapper") org.springframework.core.convert.converter.Converter<MapSE<StringSE,ObjectSE>,ObjectSE> itemKeyMapper)

    • batchItemKeyMapper

      @Bean @ConditionalOnMissingBean(name="batchItemKeyMapper") public org.springframework.core.convert.converter.Converter<MapSE<StringSE,ObjectSE>,ObjectSE> batchItemKeyMapper()