diff --git a/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java b/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
index 4b0b5d614..68a08def3 100644
--- a/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
+++ b/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
@@ -100,8 +100,8 @@ public void assertStageStopping() {
   @Test
   public void establishClientBidirectionalConnectionAndSubscribeToATopic()
       throws InterruptedException, ExecutionException, TimeoutException {
-    String clientId = "source-test/flow";
-    String topic = "source-test/topic1";
+    String clientId = "client-flow-test/flow";
+    String topic = "client-flow-test/topic1";
     ByteString uniqueSessionId = ByteString.fromString("establishClientBidirectionalConnectionAndSubscribeToATopic-session");
 
     // #create-streaming-flow
@@ -161,8 +161,8 @@ public Publish apply(DecodeErrorOrEvent<Object> x, boolean isCheck) {
   @Test
   public void establishServerBidirectionalConnectionAndSubscribeToATopic()
       throws InterruptedException, ExecutionException, TimeoutException {
-    String clientId = "flow-test/flow";
-    String topic = "source-test/topic1";
+    String clientId = "server-flow-test/flow";
+    String topic = "server-flow-test/topic1";
     ByteString uniqueSessionId = ByteString.fromString("establishServerBidirectionalConnectionAndSubscribeToATopic-connection");
     String host = "localhost";
     int port = 9884;