Skip to content

Commit f40da2d

Browse files
committed
more general error msg pattern
1 parent ffcb177 commit f40da2d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ private void onTcpSenderException(Exception e) {
247247

248248
private void onHttpSenderException(Exception e) {
249249
closeSenderSilently();
250-
if (e.getMessage() != null && e.getMessage().contains("failed to parse line protocol") || e.getMessage().contains("cast error")) { // hack to detect data parsing errors
250+
if (e.getMessage() != null && e.getMessage().contains("error in line")) { // hack to detect data parsing errors
251251
// ok, we have a parsing error, let's try to send records one by one to find the problematic record
252252
// and we will report it to the error handler. the rest of the records will make it to QuestDB
253253
sender = createSender();

0 commit comments

Comments
 (0)