in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java [180:188]
public synchronized void stop() {
LOG.info("Stopping TBSourceTask");
if (cursor != null) {
cursor.close();
}
if (timebase != null) {
timebase.close();
}
}