diff --git a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java
index b7ed031ec7..9d04541f8d 100644
--- a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java
+++ b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java
@@ -52,14 +52,13 @@ public class ConsumerFooServiceIntegrationTest {
                     .map(Arrays::stream)
                     .orElse(Stream.empty());
             })
-            .map(IThrowableProxy::getMessage)
+            .map(IThrowableProxy::getClassName)
             .collect(Collectors.toList());
         assertThat(allLoggedEntries).anyMatch(entry -> entry.contains("The following error happened on processFoo method!"))
             .anyMatch(entry -> entry.contains("| onSubscribe"))
             .anyMatch(entry -> entry.contains("| cancel()"));
 
-        assertThat(allSuppressedEntries).anyMatch(entry -> entry.contains("Assembly trace from producer"))
-            .anyMatch(entry -> entry.contains("Error has been observed by the following operator(s)"));
+        assertThat(allSuppressedEntries)
+            .anyMatch(entry -> entry.contains("reactor.core.publisher.FluxOnAssembly$OnAssemblyException"));
     }
-
 }
diff --git a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java
index af9bdfbc9b..e61ea9e155 100644
--- a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java
+++ b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java
@@ -7,6 +7,11 @@ import org.springframework.test.web.reactive.server.WebTestClient.ResponseSpec;
 
 import com.baeldung.debugging.consumer.service.FooService;
 
+/**
+ * In order to run this live test, start the following classes:
+ * - com.baeldung.debugging.server.ServerDebuggingApplication
+ * - com.baeldung.debugging.consumer.ConsumerDebuggingApplication
+ */
 public class ConsumerFooServiceLiveTest {
 
     FooService service = new FooService();