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);
diff --git a/pom.xml b/pom.xml
index 7d85deae5..fe59c308b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -89,6 +89,11 @@
objenesis
${objenesis.version}
+
+ com.fasterxml.jackson.core
+ jackson-core
+ 2.13.2
+
org.springframework.cloud
spring-cloud-stream