From 16666fcc5bd525c5905274a55221f6706bd60b70 Mon Sep 17 00:00:00 2001
From: Jaromir Hamala <jaromir.hamala@gmail.com>
Date: Mon, 9 Sep 2024 11:46:52 +0200
Subject: [PATCH] request commit after a successful flush()

This limits the number of duplicates QuestDB
server has to deal with after error recovery
---
 connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java b/connector/src/main/java/io/questdb/kafka/QuestDBSinkTask.java
index 4a803fd..dc41a5b 100644
--- 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) {