@Configuration
@EnableConfigurationProperties(value={org.springframework.boot.autoconfigure.kafka.KafkaProperties.class,KafkaItemReaderProperties.class})
@AutoConfigureAfter(value=org.springframework.boot.autoconfigure.batch.BatchAutoConfiguration.class)
public class KafkaItemReaderAutoConfiguration
extends Object
KafkaItemReader.| Constructor and Description |
|---|
KafkaItemReaderAutoConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.batch.item.kafka.KafkaItemReader<Object,Map<String,Object>> |
kafkaItemReader(KafkaItemReaderProperties kafkaItemReaderProperties) |
@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(prefix="spring.batch.job.kafkaitemreader",
name="name")
public org.springframework.batch.item.kafka.KafkaItemReader<Object,Map<String,Object>> kafkaItemReader(KafkaItemReaderProperties kafkaItemReaderProperties)
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.