🤦‍

Author: jerrinot

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

@@ -169,7 +169,7 @@ public void put(Collection<SinkRecord> collection) {
                     if (remainingMs <= 0) {
                         log.debug("Flushing data to QuestDB due to auto_flush_interval timeout");
                         flushAndResetCounters();
-                    } if (allowedLag == 0) {
+                    } else if (allowedLag == 0) {
                         log.debug("Flushing data to QuestDB due to zero allowed lag");
                         flushAndResetCounters();
                     } else {