diff --git a/runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java b/runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java
index 8c43c9781a..236c154428 100644
--- a/runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java
+++ b/runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java
@@ -5174,10 +5174,7 @@ private void onSessionWindow(
 
                 assert initialAck <= initialSeq;
 
-                if (!wasOpen || willPayloadBytes != 0)
-                {
-                    decodeNetwork(traceId);
-                }
+                decodeNetwork(traceId);
 
                 if (budgetId != 0L && debitorIndex == NO_DEBITOR_INDEX)
                 {