doc-exports/docs/apm/umn/apm_01_0066.html

RocketMqConsumer Monitoring

This section describes the types, names, and meanings of RocketMqConsumer metrics collected by APM.

Table 1 RocketMqConsumer metrics

Category	Metric	Name	Description	Unit	Data Type	Default Aggregation Mode
Exception (exception: exception statistics of RocketMqConsumer calls)	exceptionType	exceptionType	Exception type	-	ENUM	LAST
	causeType	causeType	Exception class	-	ENUM	LAST
	count	count	Number of times the exception has occurred	-	INT	SUM
	message	message	Message returned when the exception occurred	-	STRING	LAST
	stackTrace	stackTrace	Exception stack information	-	CLOB	LAST
Consumption pool monitoring (consumeServicePool)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	currentConsumeRequestQueueSize	currentConsumeRequestQueueSize	Current size of the consumption request queue	-	INT	AVG
	maxConsumeRequestQueueSize	maxConsumeRequestQueueSize	Maximum size of the consumption request queue	-	INT	MAX
	currentConsumingThreadCount	currentConsumingThreadCount	Current number of consumption threads	-	INT	AVG
	maxConsumingPoolSize	maxConsumingPoolSize	Maximum number of consumption threads	-	INT	MAX
Message listener monitoring (consumeListener: APM counts message consumption statistics by MessageListener.)	consumeListener	consumeListener	Registered message listener, which is the callback function for message consumption	-	ENUM	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent consumption	-	INT	MAX
	errorCount	errorCount	Number of message consumption errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of consumption call times	-	INT	SUM
	consumedMsgCount	consumedMsgCount	Number of messages that have been consumed	-	INT	SUM
	consumedBytes	consumedBytes	Number of bytes that have been consumed	-	INT	SUM
	reconsumeTimes	reconsumeTimes	Number of message re-consumption times	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message consumption	-	STRING	LAST
	maxTime	maxTime	Maximum response time for consuming messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being consumed at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for consuming messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Client ID monitoring (clientIdConsume: APM counts message consumption statistics by client ID.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent consumption	-	INT	MAX
	errorCount	errorCount	Number of message consumption errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of consumption call times	-	INT	SUM
	consumedMsgCount	consumedMsgCount	Number of messages that have been consumed	-	INT	SUM
	consumedBytes	consumedBytes	Number of bytes that have been consumed	-	INT	SUM
	reconsumeTimes	reconsumeTimes	Number of message re-consumption times	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message consumption	-	STRING	LAST
	maxTime	maxTime	Maximum response time for consuming messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being consumed at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for consuming messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Topic monitoring (topicConsume: APM counts message consumption statistics by topic.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	topic	topic	Topic for message consumption	-	ENUM	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent consumption	-	INT	MAX
	errorCount	errorCount	Number of message consumption errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of consumption call times	-	INT	SUM
	consumedMsgCount	consumedMsgCount	Number of messages that have been consumed	-	INT	SUM
	consumedBytes	consumedBytes	Number of bytes that have been consumed	-	INT	SUM
	reconsumeTimes	reconsumeTimes	Number of message re-consumption times	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message consumption	-	STRING	LAST
	maxTime	maxTime	Maximum response time for consuming messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being consumed at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for consuming messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Queue monitoring (queueConsume: APM counts message consumption statistics by queue.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	queue	queue	Message queue ID	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent consumption	-	INT	MAX
	errorCount	errorCount	Number of message consumption errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of consumption call times	-	INT	SUM
	consumedMsgCount	consumedMsgCount	Number of messages that have been consumed	-	INT	SUM
	consumedBytes	consumedBytes	Number of bytes that have been consumed	-	INT	SUM
	reconsumeTimes	reconsumeTimes	Number of message re-consumption times	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message consumption	-	STRING	LAST
	maxTime	maxTime	Maximum response time for consuming messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being pulled at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for pulling messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Client ID monitoring (clientIdPull: APM counts message pull statistics by client ID.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent pulling	-	INT	MAX
	errorCount	errorCount	Number of message pull errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of pull calls	-	INT	SUM
	pulledMsgCount	pulledMsgCount	Number of messages that have been pulled	-	INT	SUM
	pulledBytes	pulledBytes	Number of bytes that have been pulled	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message pulling	-	STRING	LAST
	maxTime	maxTime	Maximum response time for pulling messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being pulled at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for pulling messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Topic monitoring (topicPull: APM counts message pull statistics by topic.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	topic	topic	Topic for pulling messages	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent pulling	-	INT	MAX
	errorCount	errorCount	Number of message pull errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of pull calls	-	INT	SUM
	pulledMsgCount	pulledMsgCount	Number of messages that have been pulled	-	INT	SUM
	pulledBytes	pulledBytes	Number of bytes that have been pulled	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message pulling	-	STRING	LAST
	maxTime	maxTime	Maximum response time for pulling messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being pulled at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for pulling messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Queue monitoring (queuePull: APM counts message pull statistics by queue.)	clientId	clientId	Client instance ID	-	ENUM	LAST
	group	group	Consumer group	-	ENUM	LAST
	queue	queue	Message queue ID	-	ENUM	LAST
	pid	pid	PID	-	STRING	LAST
	concurrentMax	concurrentMax	Maximum number of messages for concurrent pulling	-	INT	MAX
	errorCount	errorCount	Number of message pull errors	-	INT	SUM
	errorTraceId	errorTraceId	ID of the trace that encounters an error in a collection period	-	STRING	LAST
	invokeCount	invokeCount	Number of pull calls	-	INT	SUM
	pulledMsgCount	pulledMsgCount	Number of messages that have been pulled	-	INT	SUM
	pulledBytes	pulledBytes	Number of bytes that have been pulled	-	INT	SUM
	lastError	lastError	Information about the error that has occurred during message pulling	-	STRING	LAST
	maxTime	maxTime	Maximum response time for pulling messages	-	INT	MAX
	runningCount	runningCount	Number of messages that are being pulled at the time of collection	-	INT	SUM
	slowTraceId	slowTraceId	ID of the slowest trace in a collection period	-	STRING	LAST
	totalTime	totalTime	Total response time for pulling messages	-	INT	SUM
	range1	range1	Number of requests with 0–10 ms response time	-	INT	SUM
	range2	range2	Number of requests with 10–100 ms response time	-	INT	SUM
	range3	range3	Number of requests with 100–200 ms response time	-	INT	SUM
	range4	range4	Number of requests with 200–1000 ms response time	-	INT	SUM
	range5	range5	Number of requests with 1–10s response time	-	INT	SUM
	range6	range6	Number of requests with response time longer than 10s	-	INT	SUM
Total monitoring (total: APM counts message consumption statistics by client.)	consumeErrorCount	consumeErrorCount	Number of message consumption errors	-	INT	SUM
	consumeInvokeCount	consumeInvokeCount	Number of consumption call times	-	INT	SUM
	consumedMsgCount	consumedMsgCount	Number of messages that have been consumed	-	INT	SUM
	consumedBytes	consumedBytes	Number of bytes that have been consumed	-	INT	SUM
	consumeTotalTime	consumeTotalTime	Total response time for consuming messages	-	INT	SUM
	reconsumeTimes	reconsumeTimes	Number of message re-consumption times	-	INT	SUM
	pullErrorCount	pullErrorCount	Number of message pull errors	-	INT	SUM
	pullInvokeCount	pullInvokeCount	Number of pull calls	-	INT	SUM
	pulledMsgCount	pulledMsgCount	Number of messages that have been pulled	-	INT	SUM
	pulledBytes	pulledBytes	Number of bytes that have been pulled	-	INT	SUM
	pullTotalTime	pullTotalTime	Total response time for pulling messages	-	INT	SUM

Parent topic: Message Queues