# KafkaConsumer监控
介绍APM采集的KafkaConsumer监控指标的类别、名称、含义等信息。
表1KafkaConsumer监控采集参数 
| 参数名         | 数据类型      | 应用类型 | 默认值 | Agent支持的起始版本 | Agent支持的终止版本 | 描述                         |
|:---|:---|:---|:---|:---|:---|:---|
| kafka慢请求阈值  | integer   | JAVA | 800 | 2.1.14       | -            | 如果有请求超过这个阈值，就会针对这个接口提高采样率。 |
| kafka消费方法配置 | obj_array | JAVA | -   | 2.1.14       | -            | kafka消费方法配置。               |
   
表2KafkaConsumer监控指标说明 
| 指标类别                                        | 指标                   | 指标名称          | 指标说明                  | 单位   | 数据类型   | 默认聚合方式 |
|:---|:---|:---|:---|:---|:---|:---|
| 主题 (topic，kafka的topic监控数据。)                 | id                   | id            | clientid和ip信息         | -    | ENUM   | LAST   |
| 主题 (topic，kafka的topic监控数据。)                 | topic                | topic         | kafka的topic名称         | -    | ENUM   | LAST   |
| 主题 (topic，kafka的topic监控数据。)                 | bytesConsumedRate    | 每秒消费字节        | 每秒消费字节                | Byte | INT    | AVG    |
| 主题 (topic，kafka的topic监控数据。)                 | fetchSizeAvg         | 请求获取平均字节      | 请求获取平均字节              | Byte | INT    | AVG    |
| 主题 (topic，kafka的topic监控数据。)                 | fetchSizeMax         | 请求获取最大字节      | 请求获取最大字节              | Byte | INT    | MAX    |
| 主题 (topic，kafka的topic监控数据。)                 | recordsConsumedRate  | 每秒消费消息数       | 每秒消费消息数               | -    | INT    | AVG    |
| 主题 (topic，kafka的topic监控数据。)                 | recordsPerRequestAvg | 单次请求平均消息数     | 单次请求平均消息数             | -    | INT    | AVG    |
| 主题 (topic，kafka的topic监控数据。)                 | seqIds               | Producer生成序列号 | Producer生成序列号         | -    | STRING | LAST   |
| 主题 (topic，kafka的topic监控数据。)                 | recordConsumedTotal  | 总消费次数         | 总消费次数                 | -    | INT    | SUM    |
| 主题 (topic，kafka的topic监控数据。)                 | bytesConsumedTotal   | 总消费字节数        | 总消费字节数                | -    | INT    | SUM    |
| fetch (fetch，kafka的fetch监控数据)               | id                   | id            | clientid和ip信息         | -    | ENUM   | LAST   |
| fetch (fetch，kafka的fetch监控数据)               | bytesConsumedRate    | 每秒消费字节        | 每秒消费字节                | Byte | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | fetchLatencyAvg      | 请求平均时延        | 请求平均时延                | ms   | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | fetchLatencyMax      | 请求最大时延        | 请求最大时延                | ms   | INT    | MAX    |
| fetch (fetch，kafka的fetch监控数据)               | fetchRate            | 每秒请求数         | 每秒请求数                 | -    | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | fetchSizeAvg         | 请求获取平均字节      | 请求获取平均字节              | Byte | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | fetchSizeMax         | 请求获取最大字节      | 请求获取最大字节              | Byte | INT    | MAX    |
| fetch (fetch，kafka的fetch监控数据)               | recordsConsumedRate  | 每秒消费消息数       | 每秒消费消息数               | -    | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | recordsLagMax        | 最大堆积消息数       | 最大堆积消息数               | -    | INT    | MAX    |
| fetch (fetch，kafka的fetch监控数据)               | recordsPerRequestAvg | 单次请求平均消息数     | 单次请求平均消息数             | -    | INT    | AVG    |
| fetch (fetch，kafka的fetch监控数据)               | seqIds               | Producer生成序列号 | Producer生成序列号         | -    | STRING | LAST   |
| fetch (fetch，kafka的fetch监控数据)               | recordConsumedTotal  | 总消费次数         | 总消费次数                 | -    | INT    | SUM    |
| fetch (fetch，kafka的fetch监控数据)               | bytesConsumedTotal   | 总消费字节数        | 总消费字节数                | -    | INT    | SUM    |
| partition (partition，kafka的partition监控数据。)  | id                   | id            | clientid和ip信息         | -    | ENUM   | LAST   |
| partition (partition，kafka的partition监控数据。)  | partition            | partition     | kafka的partition名称     | -    | ENUM   | LAST   |
| partition (partition，kafka的partition监控数据。)  | recordsLag           | 堆积消息数         | 堆积消息数                 | -    | INT    | LAST   |
| partition (partition，kafka的partition监控数据。)  | recordsLagAvg        | 平均堆积消息数       | 平均堆积消息数               | -    | INT    | AVG    |
| partition (partition，kafka的partition监控数据。)  | recordsLagMax        | 最大堆积消息数       | 最大堆积消息数               | -    | INT    | MAX    |
| partition (partition，kafka的partition监控数据。)  | seqIds               | Producer生成序列号 | Producer生成序列号         | -    | STRING | LAST   |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | method               | method        | 消费方法                  | -    | ENUM   | LAST   |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | concurrentMax        | 最大并发          | 最大并发                  | -    | INT    | MAX    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | errorCount           | 错误数           | 错误数                   | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | invokeCount          | 调用次数          | 调用次数                  | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | lastError            | 错误信息          | 发生错误时产生的错误信息          | -    | STRING | LAST   |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | maxTime              | 最大响应时间        | 采集周期内最大响应时间           | -    | INT    | MAX    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range1               | 0-10ms        | 响应时间在0-10ms范围调用次数     | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range2               | 10-100ms      | 响应时间在10-100ms范围调用次数   | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range3               | 100-500ms     | 响应时间在100-500ms范围调用次数  | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range4               | 500-1000ms    | 响应时间在500-1000ms范围调用次数 | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range5               | 1-10s         | 响应时间在1-10s范围调用次数      | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | range6               | 10s以上         | 响应时间在10s以上调用次数        | -    | INT    | SUM    |
| kafka消费方法监控 (consumer，kafka消费方法监控。)         | totalTime            | 总响应时间         | 总响应时间                 | -    | INT    | SUM    |
| KafkaConsumer汇总（total，KafkaConsumer汇总信息统计。） | recordConsumedTotal  | 总消费次数         | 总消费次数                 | -    | INT    | SUM    |
| KafkaConsumer汇总（total，KafkaConsumer汇总信息统计。） | bytesConsumedTotal   | 总消费字节数        | 总消费字节数                | -    | INT    | SUM    |
| KafkaConsumer汇总（total，KafkaConsumer汇总信息统计。） | recordsLag           | 总堆积消息数        | 总堆积消息数                | -    | INT    | LAST   |
| 异常 (exception，kafka消费异常信息。)                 | causeType            | 异常发生类         | 异常发生类                 | -    | ENUM   | LAST   |
| 异常 (exception，kafka消费异常信息。)                 | exceptionType        | 异常类           | 异常类                   | -    | ENUM   | LAST   |
| 异常 (exception，kafka消费异常信息。)                 | count                | 数量            | 异常数量                  | -    | INT    | SUM    |
| 异常 (exception，kafka消费异常信息。)                 | message              | 异常消息          | 异常消息                  | -    | STRING | LAST   |
| 异常 (exception，kafka消费异常信息。)                 | stackTrace           | 异常堆栈          | 异常堆栈                  | -    | CLOB   | LAST   |