diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java b/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java
index a3ca2335d524..2c15638814a7 100644
--- a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java
+++ b/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java
@@ -113,9 +113,9 @@ public void accept(final String messageString, final Integer sizeInBytes) throws
      */
     final var message = deserializeAirbyteMessage(messageString);
     if (Type.RECORD.equals(message.getType())) {
-      if (Strings.isNullOrEmpty(message.getRecord().getNamespace())) {
+      //if (Strings.isNullOrEmpty(message.getRecord().getNamespace())) {
         message.getRecord().setNamespace(defaultNamespace);
-      }
+      //}
       validateRecord(message);
     } else if (Type.STATE.equals(message.getType())) {
       lastState = message;