public void addTrafficInfoByPartKey(String partitionKey,
                long dltTime, int msgCnt, int msgSize) {
            PartitionStatsItemSet partStatsUnit =
                    partDltStatsMap.get(partitionKey);
            if (partStatsUnit == null) {
                PartitionStatsItemSet tmpUnit = new PartitionStatsItemSet(partitionKey);
                partStatsUnit = partDltStatsMap.putIfAbsent(partitionKey, tmpUnit);
                if (partStatsUnit == null) {
                    partStatsUnit = tmpUnit;
                }
            }
            partStatsUnit.trafficStatsUnit.addMsgCntAndSize(msgCnt, msgSize);
            partStatsUnit.msgCallDltStats.update(dltTime);
        }
Accumulate traffic information by partition

@param dltTime   the latency
@param msgCnt    the message count
@param msgSize   the message size
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/ClientStatsInfo.java