diff --git a/spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfiguration.java b/spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfiguration.java index 08e63653..ee2ec613 100644 --- a/spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfiguration.java +++ b/spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfiguration.java @@ -51,14 +51,11 @@ public class KafkaItemReaderAutoConfiguration { @Autowired private KafkaProperties kafkaProperties; - @Autowired - private SslBundles sslBundles; - @Bean @ConditionalOnMissingBean @ConditionalOnProperty(prefix = "spring.batch.job.kafkaitemreader", name = "name") public KafkaItemReader> kafkaItemReader( - KafkaItemReaderProperties kafkaItemReaderProperties) { + KafkaItemReaderProperties kafkaItemReaderProperties, SslBundles sslBundles) { Properties consumerProperties = new Properties(); consumerProperties.putAll(this.kafkaProperties.getConsumer().buildProperties(sslBundles)); validateProperties(kafkaItemReaderProperties);