in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [218:225]
public synchronized void rollback() throws IOException {
if (countingStream != null) {
countingStream.close();
if (currentFile != null && currentFile.file != null) {
dumpFile();
}
}
}