better msg pattern

questdb · Sep 9, 2024 · a910647 · a910647
1 parent 7bd5e6d
commit a910647
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java b/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java
@@ -255,7 +255,10 @@ private void onTcpSenderException(Exception e) {
 
     private void onHttpSenderException(Exception e) {
         closeSenderSilently();
-        if (reporter != null & e.getMessage() != null && e.getMessage().contains("error in line")) { // hack to detect data parsing errors
+        if (
+                (reporter != null && e.getMessage() != null) // hack to detect data parsing errors
+                && (e.getMessage().contains("error in line") || e.getMessage().contains("failed to parse line protocol"))
+        ) {
             // ok, we have a parsing error, let's try to send records one by one to find the problematic record
             // and we will report it to the error handler. the rest of the records will make it to QuestDB
             sender = createSender();