From 7fc2b00ce101ac9686cbac5d0ebad0bf57a685cb Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Fri, 22 Apr 2022 15:11:09 +0200
Subject: [PATCH] GH-2340 Fix CCE in extended properties

Resolves #2340
---
 .../cloud/stream/binding/BindingService.java                | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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