diff --git a/pom.xml b/pom.xml
index 37c80141e..9d1e6a5c4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,8 +66,8 @@
 		<spring-cloud-commons.version>3.0.5-SNAPSHOT</spring-cloud-commons.version>
 		<spring-cloud-gateway.version>3.0.5-SNAPSHOT</spring-cloud-gateway.version>
 		<spring-cloud-circuitbreaker.version>2.0.3-SNAPSHOT</spring-cloud-circuitbreaker.version>
-		<spring-cloud-stream.version>3.1.4</spring-cloud-stream.version>
-		<spring-cloud-function.version>3.1.4</spring-cloud-function.version>
+		<spring-cloud-stream.version>3.1.6</spring-cloud-stream.version>
+		<spring-cloud-function.version>3.1.6</spring-cloud-function.version>
 		<spring-cloud-netflix.version>3.0.5-SNAPSHOT</spring-cloud-netflix.version>
 		<spring-cloud-openfeign.version>3.0.5-SNAPSHOT</spring-cloud-openfeign.version>
 		<brave.version>5.13.2</brave.version>
diff --git a/tests/common/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapperTests.java b/tests/common/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapperTests.java
index df29fcc70..c944729b8 100644
--- a/tests/common/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapperTests.java
+++ b/tests/common/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapperTests.java
@@ -55,7 +55,7 @@ public abstract class TraceFunctionAroundWrapperTests {
 
 			Message<?> result = (Message<?>) function.get();
 
-			assertThat(result.getPayload()).isEqualTo("hello".getBytes());
+			assertThat(result.getPayload()).isEqualTo("hello");
 			assertThat(spanHandler.reportedSpans().size()).isEqualTo(2);
 			assertThat(((String) result.getHeaders().get("b3"))).contains(spanHandler.get(0).getTraceId());
 			spanHandler.assertAllSpansWereFinishedOrAbandoned(context.getBean(TestTracer.class).createdSpans());