SBFM changes for Boot 3.2/3.3 compatibility

spring-cloud · Apr 12, 2024 · 5fb122e · 5fb122e
1 parent 5ab62e1
commit 5fb122e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...a/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java b/...a/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
@@ -103,8 +103,8 @@ public synchronized void start() {
 					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);