SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SBFM changes for Boot 3.2/3.3 compatibility

Browse Source
This commit is contained in:
Soby Chacko
2024-04-12 17:40:52 -04:00
parent 5ab62e1aa1
commit 5fb122e5a9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
View File

@@ -103,8 +103,8 @@ public class StreamsBuilderFactoryManager implements SmartLifecycle {
final List<ConsumerProperties> consumerProperties = bindingServicePropertiesPerSbfb.get(streamsBuilderFactoryBean);
final boolean autoStartupDisabledOnAtLeastOneConsumerBinding = consumerProperties.stream().anyMatch(consumerProperties1 -> !consumerProperties1.isAutoStartup());
if (!autoStartupDisabledOnAtLeastOneConsumerBinding) {
if (streamsBuilderFactoryBean instanceof SmartInitializingSingleton sbfb) {
sbfb.afterSingletonsInstantiated();
if (streamsBuilderFactoryBean instanceof SmartInitializingSingleton) {
((SmartInitializingSingleton) streamsBuilderFactoryBean).afterSingletonsInstantiated();
}
streamsBuilderFactoryBean.start();
this.kafkaStreamsRegistry.registerKafkaStreams(streamsBuilderFactoryBean);