更新时间:2023-08-02 GMT+08:00

KafkaConsumer监控

介绍APM采集的KafkaConsumer监控指标的类别、名称、含义等信息。

表1 KafkaConsumer监控采集参数

参数名

数据类型

应用类型

默认值

Agent支持的起始版本

Agent支持的终止版本

描述

kafka慢请求阈值

integer

JAVA

800

2.1.14

-

超过慢请求阈值的方法提高采样率。

kafka消费方法配置

obj_array

JAVA

-

2.1.14

-

kafka消费方法配置。

表2 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