Do not treat result parse exception as malformed

vinted · Dec 18, 2023 · f9de741 · f9de741
1 parent 0e93214
commit f9de741
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/com/vinted/kafka/connect/vespa/feeders/VespaFeederHandler.java b/src/main/java/com/vinted/kafka/connect/vespa/feeders/VespaFeederHandler.java
@@ -3,6 +3,7 @@
 import ai.vespa.feed.client.DocumentId;
 import ai.vespa.feed.client.OperationParseException;
 import ai.vespa.feed.client.Result;
+import ai.vespa.feed.client.ResultParseException;
 import com.fasterxml.jackson.core.JsonParseException;
 import com.vinted.kafka.connect.vespa.VespaReporter;
 import com.vinted.kafka.connect.vespa.VespaSinkConfig;
@@ -108,10 +109,11 @@ private static boolean isMalformed(Throwable throwable) {
 
         String rootCauseString = rootCause.toString().toLowerCase();
 
-        return rootCauseString.contains("status 400")
+        return !(rootCause instanceof ResultParseException)
+                && (rootCauseString.contains("status 400")
                 || rootCauseString.contains("string field value contains illegal code point")
                 || rootCause instanceof OperationParseException
-                || rootCause instanceof JsonParseException;
+                || rootCause instanceof JsonParseException);
     }
 
     private static Result ignoredResult() {