public synchronized void updateSetting(RealtimeSetting newSetting) {
        if (state == State.CLOSE) {
            return;
        }
        logger.info("Updating realtime table setting. [table: {}]", tableName);

        if (newSetting == null) {
            stop();
            setting = null;
            state = State.STOP;
            return;
        }
        if (!newSetting.equals(setting)) {
            RealtimeSetting oldSetting = setting;
            setting = newSetting;
            if (oldSetting != null) {
                Try.on(oldSetting.fetcher::close, logger);
            }
            //safeInterruptIngest();
        }
    }
Stop ingesting events into this realtime table.
indexr-segment/src/main/java/io/indexr/segment/rt/RealtimeTable.java