RocketMqConsumer Monitoring¶
This section describes the types, names, and meanings of RocketMqConsumer metrics collected by APM.
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 |