diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java
index 25fc0f2f8..81e2e4a24 100644
--- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java
+++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java
@@ -145,7 +145,11 @@ public class BindingService {
 							continue;
 						}
 
-						ConsumerProperties consumerPropertiesTemp = new ExtendedConsumerProperties<>("");
+						Object extensiion = consumerProperties instanceof ExtendedConsumerProperties
+								? ((ExtendedConsumerProperties) consumerProperties).getExtension()
+										: null;
+
+						ConsumerProperties consumerPropertiesTemp = new ExtendedConsumerProperties<>(extensiion);
 						BeanUtils.copyProperties(consumerProperties, consumerPropertiesTemp);
 
 						consumerPropertiesTemp.setInstanceIndex(index);