KafkaConsumer监控
介绍APM采集的KafkaConsumer监控指标的类别、名称、含义等信息。
参数名 |
数据类型 |
应用类型 |
默认值 |
Agent支持的起始版本 |
Agent支持的终止版本 |
描述 |
|---|---|---|---|---|---|---|
kafka慢请求阈值 |
integer |
JAVA |
800 |
2.1.14 |
- |
超过慢请求阈值的方法提高采样率。 |
kafka消费方法配置 |
obj_array |
JAVA |
- |
2.1.14 |
- |
kafka消费方法配置。 |
指标类别 |
指标 |
指标名称 |
指标说明 |
单位 |
数据类型 |
默认聚合方式 |
|---|---|---|---|---|---|---|
主题 (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 |
