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