KafkaConsumer監控
更新時間 2024-03-11 11:36:05
最近更新時間: 2024-03-11 11:36:05
分享文章
本文主要介紹KafkaConsumer監控
介紹APM采集的KafkaConsumer監控指標的類別、名稱、含義等信息。
表 KafkaConsumer監控采集參數
| 參數名 | 數據類型 | 應用類型 | 默認值 | Agent支持的起始版本 | Agent支持的終止版本 | 描述 |
|---|---|---|---|---|---|---|
| kafka慢請求閾值 | integer | JAVA | 800 | 2.1.14 | - | 超過慢請求閾值的方法提高采樣率。 |
| kafka消費方法配置 | obj_array | JAVA | - | 2.1.14 | - | kafka消費方法配置。 |
表 KafkaConsumer監控指標說明
指標類別 指標 指標名稱 指標說明 單位 數據類型 默認聚合方式 主題 (topic，kafka的topic監控數據。) id id clientid和ip信息 - ENUM LAST topic topic kafka的topic名稱 - ENUM LAST bytesConsumedRate 每秒消費字節 每秒消費字節 Byte INT AVG fetchSizeAvg 請求獲取平均字節 請求獲取平均字節 Byte INT AVG fetchSizeMax 請求獲取最大字節 請求獲取最大字節 Byte INT MAX recordsConsumedRate 每秒消費消息數 每秒消費消息數 - INT AVG recordsPerRequestAvg 單次請求平均消息數 單次請求平均消息數 - INT AVG seqIds Producer生成序列號 Producer生成序列號 - STRING LAST recordConsumedTotal 總消費次數 總消費次數 - INT SUM bytesConsumedTotal 總消費字節數 總消費字節數 - INT SUM fetch (fetch，kafka的fetch監控數據) id id clientid和ip信息 - ENUM LAST bytesConsumedRate 每秒消費字節 每秒消費字節 Byte INT AVG fetchLatencyAvg 請求平均時延 請求平均時延 ms INT AVG fetchLatencyMax 請求最大時延 請求最大時延 ms INT MAX fetchRate 每秒請求數 每秒請求數 - INT AVG fetchSizeAvg 請求獲取平均字節 請求獲取平均字節 Byte INT AVG fetchSizeMax 請求獲取最大字節 請求獲取最大字節 Byte INT MAX recordsConsumedRate 每秒消費消息數 每秒消費消息數 - INT AVG recordsLagMax 最大堆積消息數 最大堆積消息數 - INT MAX recordsPerRequestAvg 單次請求平均消息數 單次請求平均消息數 - INT AVG seqIds Producer生成序列號 Producer生成序列號 - STRING LAST recordConsumedTotal 總消費次數 總消費次數 - INT SUM bytesConsumedTotal 總消費字節數 總消費字節數 - INT SUM partition (partition，kafka的partition監控數據。) id id clientid和ip信息 - ENUM LAST partition partition kafka的partition名稱 - ENUM LAST recordsLag 堆積消息數 堆積消息數 - INT LAST recordsLagAvg 平均堆積消息數 平均堆積消息數 - INT AVG recordsLagMax 最大堆積消息數 最大堆積消息數 - INT MAX seqIds Producer生成序列號 Producer生成序列號 - STRING LAST kafka消費方法監控 (consumer，kafka消費方法監控。) method method 消費方法 - ENUM LAST concurrentMax 最大并發 最大并發 - INT MAX errorCount 錯誤數 錯誤數 - INT SUM invokeCount 調用次數 調用次數 - INT SUM lastError 錯誤信息 發生錯誤時產生的錯誤信息 - STRING LAST maxTime 最大響應時間 采集周期內最大響應時間 - INT MAX range1 0-10ms 響應時間在0-10ms范圍調用次數 - INT SUM range2 10-100ms 響應時間在10-100ms范圍調用次數 - INT SUM range3 100-500ms 響應時間在100-500ms范圍調用次數 - INT SUM range4 500-1000ms 響應時間在500-1000ms范圍調用次數 - INT SUM range5 1-10s 響應時間在1-10s范圍調用次數 - INT SUM range6 10s以上 響應時間在10s以上調用次數 - INT SUM totalTime 總響應時間 總響應時間 - INT SUM KafkaConsumer匯總（total，KafkaConsumer匯總信息統計。） recordConsumedTotal 總消費次數 總消費次數 - INT SUM bytesConsumedTotal 總消費字節數 總消費字節數 - INT SUM recordsLag 總堆積消息數 總堆積消息數 - INT LAST 異常 (exception，kafka消費異常信息。) causeType 異常發生類 異常發生類 - ENUM LAST exceptionType 異常類 異常類 - ENUM LAST count 數量 異常數量 - INT SUM message 異常消息 異常消息 - STRING LAST stackTrace 異常堆棧 異常堆棧 - CLOB LAST
