@Override
    protected void loopProcess(StringBuilder strBuff) {
        try {
            // Snapshot metric data and output data to file
            output2file(writableIndex.getAndIncrement());
        } catch (Throwable throwable) {
            logger.error("[Traffic Stats] Daemon commit thread throw error ", throwable);
        }
    }
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