Remove validation

airbytehq · Oct 3, 2023 · 7671134 · 7671134
1 parent f3a8dc0
commit 7671134
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -116,7 +116,7 @@ public void accept(final String messageString, final Integer sizeInBytes) throws
       //if (Strings.isNullOrEmpty(message.getRecord().getNamespace())) {
         message.getRecord().setNamespace(defaultNamespace);
       //}
-      validateRecord(message);
+      // validateRecord(message);
     } else if (Type.STATE.equals(message.getType())) {
       lastState = message;
     }