in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/RawMessageDataFeeder.java [164:169]
public void close() {
if (cursor != null && !cursor.isClosed()) {
LOG.info().append("Closing cursor for stream: ").append(stream.getName()).commit();
cursor.close();
}
}