@Override
        public void run() {
            try {
                if (totalTubeSuccSendSize.get() != 0) {
                    logger.info("Total tube performance tps :"
                            + totalTubeSuccSendCnt.get() / PRINT_INTERVAL
                            + "/s, avg msg size:"
                            + totalTubeSuccSendSize.get() / totalTubeSuccSendCnt.get()
                            + ",print every " + PRINT_INTERVAL + " seconds");

                    // totalpulsarSuccSendCnt represents the number of packets
                    totalTubeSuccSendSize.set(0);
                    totalTubeSuccSendCnt.set(0);
                }

            } catch (Exception e) {
                logger.info("tubePerformanceTask error", e);
            }
        }
Currently, all topics are published by the same producer. If needed, extend it to multi producers.

@param topic
@throws TubeClientException
inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/TubeSink.java