Precommit offset fix (#33)

* merged Azure/master

* offset fix for preCommit()

Co-authored-by: fahad <hasher@192.168.0.102>

src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java

@@ -418,7 +418,7 @@ public class KustoSinkTask extends SinkTask {
                 throw new ConnectException("Topic Partition not configured properly. " +
                         "verify your `topics` and `kusto.tables.topics.mapping` configurations");
             }
-            Long offset = writers.get(tp).lastCommittedOffset;
+            Long offset = writers.get(tp).lastCommittedOffset + 1;
 
             if (offset != null) {
                 log.debug("Forwarding to framework request to commit offset: {} for {} while the offset is {}", offset, tp, offsets.get(tp));