(資料圖)

在沒有監控的情況下可以這么看

查看topic 一天的消費速率

#!/bin/shbrokers="ip:port"topic="CMP_RADUIS_OLL_TOPIC"path="/app/ctgkafka/ctg_kafka_instance/13/icc-5gcmp-kafka/1/bin"y1=`date -d "24 hour ago" +"%Y-%m-%d %H:%M:%S"`y2=`date "+%Y-%m-%d %H:%M:%S"`yesterday1=`date -d "${y1}" +%s000`yesterday2=`date -d "${y2}" +%s000`last=0now=0speed=0    echo "【-------開始統計，當前統計時間為`date`----】"    last=$(${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday1} |  awk -F ":" "{sum1+=$NF} END {print sum1}")    now=$(${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday2} |  awk -F ":" "{sum+=$NF} END {print sum}")    let speed=(now-last)/86400    echo "昨日1天總計消費：`expr $now - $last`張,平均 TPS= $speed 張/秒"

查看一小時的消費速率

#!/bin/shbrokers="ip:port"topic="CMP_RADUIS_OLL_TOPIC"path="/app/ctgkafka/ctg_kafka_instance/13/icc-5gcmp-kafka/1/bin"#y1=`date -d "1 hour ago" +"%Y-%m-%d %H:%M:%S"`#y2=`date "+%Y-%m-%d %H:%M:%S"`y1="2022-06-12 09:12:00"y2="2022-06-12 10:12:00"yesterday1=`date -d "${y1}" +%s000`# 轉換時間戳yesterday2=`date -d "${y2}" +%s000`echo "$old date:${y1},now day:${y2} ; old yest:${yesterday1},now yest:${yesterday2}"#打印時間戳last=0now=0speed=0#hourago=`date -d "1 hour ago" +"%T"`#nowtime=`date  +"%T"`hourago=`date -d "${y1}" +"%T"`nowtime=`date -d "${y2}" +"%T"`    echo "【-------開始統計，當前統計時間為 ${nowtime}----】" >>/app/ctgpaas/kafka_count_log.log        echo "${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday1}"    echo "${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday2}"    last=$(${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday1} |  awk -F ":" "{sum1+=$NF} END {print sum1}")    now=$(${path}/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ${brokers} --topic ${topic} --time ${yesterday2} |  awk -F ":" "{sum+=$NF} END {print sum}")    let speed=(now-last)/3600    echo " ${hourago}到 ${nowtime} 總計消費：`expr $now - $last`張,平均 TPS= $speed 張/秒" >>/app/ctgpaas/kafka_count_log.log