diff --git a/pom.xml b/pom.xml
index 98fe256e..45227455 100755
--- a/pom.xml
+++ b/pom.xml
@@ -110,7 +110,7 @@
 	</modules>
 
 	<properties>
-		<spring-cloud-stream.version>3.1.4-SNAPSHOT</spring-cloud-stream.version>
+		<spring-cloud-stream.version>3.2.0-SNAPSHOT</spring-cloud-stream.version>
 		<spring-cloud-deployer.version>2.5.0</spring-cloud-deployer.version>
 		<spring-cloud-deployer-local.version>2.5.0
 		</spring-cloud-deployer-local.version>
diff --git a/spring-cloud-starter-single-step-batch-job/pom.xml b/spring-cloud-starter-single-step-batch-job/pom.xml
index 1a2746a5..39d3ad69 100644
--- a/spring-cloud-starter-single-step-batch-job/pom.xml
+++ b/spring-cloud-starter-single-step-batch-job/pom.xml
@@ -14,7 +14,7 @@
 		<test.rabbit.containers.version>1.15.3</test.rabbit.containers.version>
 		<test.ducttape.version>1.0.8</test.ducttape.version>
 		<spring-kafka-version>2.8.0-M1</spring-kafka-version>
-		<spring-cloud-stream.version>3.1.4-SNAPSHOT</spring-cloud-stream.version>
+		<spring-cloud-stream.version>3.2.0-SNAPSHOT</spring-cloud-stream.version>
 	</properties>
 
 	<dependencies>
diff --git a/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/TaskEventTests.java b/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/TaskEventTests.java
index 4c27460e..a5466c73 100644
--- a/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/TaskEventTests.java
+++ b/spring-cloud-task-integration-tests/src/test/java/org/springframework/cloud/task/listener/TaskEventTests.java
@@ -33,7 +33,7 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.context.runner.ApplicationContextRunner;
 import org.springframework.cloud.stream.annotation.EnableBinding;
 import org.springframework.cloud.stream.annotation.StreamListener;
-import org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration;
+import org.springframework.cloud.stream.binder.rabbit.config.RabbitConfiguration;
 import org.springframework.cloud.stream.config.BindingServiceConfiguration;
 import org.springframework.cloud.stream.messaging.Sink;
 import org.springframework.cloud.task.configuration.EnableTask;
@@ -72,7 +72,7 @@ public class TaskEventTests {
 		ApplicationContextRunner applicationContextRunner = new ApplicationContextRunner()
 				.withConfiguration(AutoConfigurations.of(TaskEventAutoConfiguration.class,
 						PropertyPlaceholderAutoConfiguration.class,
-						RabbitServiceAutoConfiguration.class,
+						RabbitConfiguration.class,
 						SimpleTaskAutoConfiguration.class,
 						BindingServiceConfiguration.class))
 				.withUserConfiguration(TaskEventsConfiguration.class)
diff --git a/spring-cloud-task-samples/batch-events/pom.xml b/spring-cloud-task-samples/batch-events/pom.xml
index 74cfed7b..9027083f 100644
--- a/spring-cloud-task-samples/batch-events/pom.xml
+++ b/spring-cloud-task-samples/batch-events/pom.xml
@@ -23,7 +23,7 @@
 		<test.containers.version>1.15.3</test.containers.version>
 		<test.rabbit.containers.version>1.15.3</test.rabbit.containers.version>
 		<test.ducttape.version>1.0.8</test.ducttape.version>
-		<spring.cloud.stream>3.1.4-SNAPSHOT</spring.cloud.stream>
+		<spring.cloud.stream>3.2.0-SNAPSHOT</spring.cloud.stream>
 	</properties>
 
 	<dependencyManagement>
diff --git a/spring-cloud-task-samples/task-events/pom.xml b/spring-cloud-task-samples/task-events/pom.xml
index 4d5ac6ee..5033a3db 100644
--- a/spring-cloud-task-samples/task-events/pom.xml
+++ b/spring-cloud-task-samples/task-events/pom.xml
@@ -20,7 +20,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<java.version>1.8</java.version>
-		<spring-cloud-stream>3.1.1-SNAPSHOT</spring-cloud-stream>
+		<spring-cloud-stream>3.2.0-SNAPSHOT</spring-cloud-stream>
 	</properties>
 
 	<dependencyManagement>
diff --git a/spring-cloud-task-samples/taskprocessor/pom.xml b/spring-cloud-task-samples/taskprocessor/pom.xml
index 8769e1bd..7b85ee3e 100644
--- a/spring-cloud-task-samples/taskprocessor/pom.xml
+++ b/spring-cloud-task-samples/taskprocessor/pom.xml
@@ -21,7 +21,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<skipInstall>true</skipInstall>
-		<spring-cloud-stream>3.1.1-SNAPSHOT</spring-cloud-stream>
+		<spring-cloud-stream>3.2.0-SNAPSHOT</spring-cloud-stream>
 	</properties>
 
 	<dependencyManagement>
diff --git a/spring-cloud-task-samples/tasksink/pom.xml b/spring-cloud-task-samples/tasksink/pom.xml
index e30abb4a..53c44e3d 100644
--- a/spring-cloud-task-samples/tasksink/pom.xml
+++ b/spring-cloud-task-samples/tasksink/pom.xml
@@ -22,7 +22,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<skipInstall>true</skipInstall>
-		<spring-cloud-stream>3.1.1-SNAPSHOT</spring-cloud-stream>
+		<spring-cloud-stream>3.2.0-SNAPSHOT</spring-cloud-stream>
 	</properties>
 
 	<dependencyManagement>