@Override
    public void close(long waitTimeMs) {
        if (super.stop()) {
            return;
        }
        // Output remain information
        output2file(writableIndex.get() - 1);
        output2file(writableIndex.get());
    }
Initial traffic statistics service

@param logFileName      the output file name
@param countType        the statistic type
@param scanIntervalMs   the snapshot interval
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/stats/TrafficStatsService.java