From 5fb122e5a9e429533846fff86d903451201f5637 Mon Sep 17 00:00:00 2001
From: Soby Chacko <soby.chacko@broadcom.com>
Date: Fri, 12 Apr 2024 17:40:52 -0400
Subject: [PATCH] SBFM changes for Boot 3.2/3.3 compatibility

---
 .../binder/kafka/streams/StreamsBuilderFactoryManager.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
index fb59e7dd8..a93f8dfdf 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
@@ -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);