diff --git a/services/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java b/services/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java
index ded2d421fa..8ea920c94d 100644
--- a/services/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java
+++ b/services/utils/akka/src/test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java
@@ -67,7 +67,7 @@ public void tearDownBase() {
     public void streamWithTimeout() {
         new TestKit(actorSystem) {
             {
-                final ActorRef streamForwarder = createStreamForwarder();
+                final ActorRef streamForwarder = createStreamForwarder(Duration.ofMillis(100));
                 watch(streamForwarder);
 
                 streamForwarder.tell(KNOWN_TAG_1, ActorRef.noSender());
@@ -143,12 +143,16 @@ private StreamAck failureResponse(final String tag) {
         return StreamAck.failure(tag);
     }
 
-    private ActorRef createStreamForwarder() {
+    private ActorRef createStreamForwarder(final Duration maxIdleTime) {
         // for simplicity, just use String as elementClass
-        final Props props = DefaultStreamForwarder.props(recipient.ref(), completionRecipient.ref(), MAX_IDLE_TIME,
+        final Props props = DefaultStreamForwarder.props(recipient.ref(), completionRecipient.ref(), maxIdleTime,
                 String.class, String::toString);
 
         return actorSystem.actorOf(props);
     }
 
-}
\ No newline at end of file
+    private ActorRef createStreamForwarder() {
+        return createStreamForwarder(MAX_IDLE_TIME);
+    }
+
+}