request commit after a successful flush() (#28)

This limits the number of duplicates QuestDB server has to deal with after error recovery
questdb · Sep 9, 2024 · af36753 · af36753
1 parent b4510d1
commit af36753
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java b/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java
@@ -224,6 +224,7 @@ private void flushAndResetCounters() {
             if (sender != null) {
                 sender.flush();
             }
+            context.requestCommit();
             nextFlushNanos = System.nanoTime() + flushConfig.autoFlushNanos;
             pendingRows = 0;
         } catch (LineSenderException | HttpClientException e) {