From a648d9ede5cdb6e403a94636e670f00b7ccb395a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Nicoll?= Date: Wed, 6 Aug 2025 16:54:39 +0200 Subject: [PATCH] Polish "Use Kafka's StreamsBuilderFactoryBeanConfigurer" See gh-46675 --- .../docs/antora/modules/reference/pages/messaging/kafka.adoc | 3 ++- .../KafkaStreamsAnnotationDrivenConfiguration.java | 5 ++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc b/documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc index cc430356bc2..048ec38f723 100644 --- a/documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc +++ b/documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc @@ -74,7 +74,8 @@ include-code::MyKafkaStreamsConfiguration[] By default, the streams managed by the javadoc:org.apache.kafka.streams.StreamsBuilder[] object are started automatically. You can customize this behavior using the configprop:spring.kafka.streams.auto-startup[] property. -TIP: For advanced configuration, the arbitrary javadoc:org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer[] beans can be registered to configure the javadoc:org.springframework.kafka.config.StreamsBuilderFactoryBean[] bean before the javadoc:org.apache.kafka.streams.StreamsBuilder[] bean is initialized. +TIP: You can also register an arbitrary number of beans that implement javadoc:org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer[] for more advanced customizations. + [[messaging.kafka.additional-properties]] diff --git a/module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java b/module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java index 9012132edc7..1c718496006 100644 --- a/module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java +++ b/module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java @@ -87,12 +87,11 @@ class KafkaStreamsAnnotationDrivenConfiguration { KafkaAutoConfiguration.applySslBundle(properties, streams.getSslBundle()); } - private static final class KafkaPropertiesStreamsBuilderFactoryBeanConfigurer - implements StreamsBuilderFactoryBeanConfigurer { + static class KafkaPropertiesStreamsBuilderFactoryBeanConfigurer implements StreamsBuilderFactoryBeanConfigurer { private final KafkaProperties properties; - private KafkaPropertiesStreamsBuilderFactoryBeanConfigurer(KafkaProperties properties) { + KafkaPropertiesStreamsBuilderFactoryBeanConfigurer(KafkaProperties properties) { this.properties = properties; }