in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [232:239]
public synchronized void stop() throws DataException {
stopped = true;
if (timer != null) {
Timer temp = timer;
timer = null;
temp.cancel();
}
}