From 15d78eb43aca81f4a5440b0e73798af3fb94509f Mon Sep 17 00:00:00 2001 From: Glenn Renfro Date: Thu, 19 Oct 2023 12:08:55 -0400 Subject: [PATCH] Ssl bundle needs to be passed in as a parameter it was autowired --- .../kafka/KafkaItemReaderAutoConfiguration.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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);