diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java index ba0968b9f9..662423c3a8 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java @@ -238,7 +238,7 @@ public class KafkaAutoConfiguration { static void applySslBundle(Map properties, SslBundle sslBundle) { if (sslBundle != null) { - properties.put(SslConfigs.SSL_ENGINE_FACTORY_CLASS_CONFIG, SslBundleSslEngineFactory.class.getName()); + properties.put(SslConfigs.SSL_ENGINE_FACTORY_CLASS_CONFIG, SslBundleSslEngineFactory.class); properties.put(SslBundle.class.getName(), sslBundle); } } diff --git a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java index add0f3f073..82962c65c5 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java @@ -216,8 +216,7 @@ class KafkaAutoConfigurationTests { assertThat(context).hasSingleBean(KafkaConnectionDetails.class); DefaultKafkaConsumerFactory consumerFactory = context.getBean(DefaultKafkaConsumerFactory.class); Map configs = consumerFactory.getConfigurationProperties(); - assertThat(configs).containsEntry("ssl.engine.factory.class", - "org.springframework.boot.autoconfigure.kafka.SslBundleSslEngineFactory"); + assertThat(configs).containsEntry("ssl.engine.factory.class", SslBundleSslEngineFactory.class); assertThat(configs).containsEntry("org.springframework.boot.ssl.SslBundle", sslBundle); }); } @@ -310,8 +309,7 @@ class KafkaAutoConfigurationTests { assertThat(context).hasSingleBean(KafkaConnectionDetails.class); DefaultKafkaProducerFactory producerFactory = context.getBean(DefaultKafkaProducerFactory.class); Map configs = producerFactory.getConfigurationProperties(); - assertThat(configs).containsEntry("ssl.engine.factory.class", - "org.springframework.boot.autoconfigure.kafka.SslBundleSslEngineFactory"); + assertThat(configs).containsEntry("ssl.engine.factory.class", SslBundleSslEngineFactory.class); assertThat(configs).containsEntry("org.springframework.boot.ssl.SslBundle", sslBundle); }); } @@ -394,8 +392,7 @@ class KafkaAutoConfigurationTests { assertThat(context).hasSingleBean(KafkaConnectionDetails.class); KafkaAdmin admin = context.getBean(KafkaAdmin.class); Map configs = admin.getConfigurationProperties(); - assertThat(configs).containsEntry("ssl.engine.factory.class", - "org.springframework.boot.autoconfigure.kafka.SslBundleSslEngineFactory"); + assertThat(configs).containsEntry("ssl.engine.factory.class", SslBundleSslEngineFactory.class); assertThat(configs).containsEntry("org.springframework.boot.ssl.SslBundle", sslBundle); }); } @@ -490,8 +487,7 @@ class KafkaAutoConfigurationTests { .getBean(KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME, KafkaStreamsConfiguration.class) .asProperties(); - assertThat(configs).containsEntry("ssl.engine.factory.class", - "org.springframework.boot.autoconfigure.kafka.SslBundleSslEngineFactory"); + assertThat(configs).containsEntry("ssl.engine.factory.class", SslBundleSslEngineFactory.class); assertThat(configs).containsEntry("org.springframework.boot.ssl.SslBundle", sslBundle); }); }