spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-09-17 12:09:16 +00:00
Code Issues Projects Releases Wiki Activity

Polish "Use Kafka's StreamsBuilderFactoryBeanConfigurer"

Browse Source 
See gh-46675
This commit is contained in:
Stéphane Nicoll
2025-08-07 09:53:50 +02:00
parent a6668ca22e
commit a648d9ede5
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
documentation/spring-boot-docs/src/docs/antora/modules/reference/pages/messaging/kafka.adoc
+2 -1
View File
@@ -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]]
module/spring-boot-kafka/src/main/java/org/springframework/boot/kafka/autoconfigure/KafkaStreamsAnnotationDrivenConfiguration.java
+2 -3
View File
@@ -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;
}