diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
index 49fc64488..d76762724 100644
--- a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
+++ b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
@@ -63,7 +63,7 @@ public class StreamFunctionAdapterTests {
 
 		Message<byte[]> message = this.outputDestination.receive(200L);
 		assertThat(message).isNotNull();
-		assertThat(message.getPayload()).isEqualTo("HELLO".getBytes());
+		assertThat(message.getPayload()).isEqualTo("\"HELLO\"".getBytes());
 		String b3 = message.getHeaders().get("b3", String.class);
 		assertThat(b3).startsWith("4883117762eb9420");
 
diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java
index f3d8be101..1eb85f8a6 100644
--- a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java
+++ b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java
@@ -68,7 +68,7 @@ public class StreamMessageOperatorsTests {
 
 		Message<byte[]> message = this.outputDestination.receive(200L);
 		assertThat(message).isNotNull();
-		assertThat(message.getPayload()).isEqualTo("HELLO".getBytes());
+		assertThat(message.getPayload()).isEqualTo("\"HELLO\"".getBytes());
 		String b3 = message.getHeaders().get("b3", String.class);
 		assertThat(b3).startsWith("4883117762eb9420");