in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriter.java [274:276]
void stop() { fileWriter.stop(); }