Skip to content

Commit a648d9e

Browse files
committed
Polish "Use Kafka's StreamsBuilderFactoryBeanConfigurer"
See gh-46675
1 parent a6668ca commit a648d9e

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,8 @@ include-code::MyKafkaStreamsConfiguration[]
7474
By default, the streams managed by the javadoc:org.apache.kafka.streams.StreamsBuilder[] object are started automatically.
7575
You can customize this behavior using the configprop:spring.kafka.streams.auto-startup[] property.
7676

77-
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.
77+
TIP: You can also register an arbitrary number of beans that implement javadoc:org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer[] for more advanced customizations.
78+
7879

7980

8081
[[messaging.kafka.additional-properties]]

module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,12 +87,11 @@ private void applyKafkaConnectionDetailsForStreams(Map<String, Object> propertie
8787
KafkaAutoConfiguration.applySslBundle(properties, streams.getSslBundle());
8888
}
8989

90-
private static final class KafkaPropertiesStreamsBuilderFactoryBeanConfigurer
91-
implements StreamsBuilderFactoryBeanConfigurer {
90+
static class KafkaPropertiesStreamsBuilderFactoryBeanConfigurer implements StreamsBuilderFactoryBeanConfigurer {
9291

9392
private final KafkaProperties properties;
9493

95-
private KafkaPropertiesStreamsBuilderFactoryBeanConfigurer(KafkaProperties properties) {
94+
KafkaPropertiesStreamsBuilderFactoryBeanConfigurer(KafkaProperties properties) {
9695
this.properties = properties;
9796
}
9897

0 commit comments

Comments
 (0)