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);