force namespace

airbytehq · Oct 2, 2023 · f3a8dc0 · f3a8dc0
1 parent e396025
commit f3a8dc0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...core/src/main/java/io/airbyte/cdk/integrations/destination_async/AsyncStreamConsumer.java b/...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;