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 | Exception Type | Exception type | - | ENUM | LAST |
causeType | Exception Class | Exception class | - | ENUM | LAST | |
count | Count | Number of times the exception has occurred | - | INT | SUM | |
message | Exception Message | Message returned when the exception occurred | - | STRING | LAST | |
stackTrace | Exception Stack | Exception stack information | - | CLOB | LAST | |
Consumption pool monitoring (consumeServicePool) | clientId | clientId | Client instance ID | - | ENUM | LAST |
group | consumerGroup | Consumer group | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
currentConsumeRequestQueueSize | Current Size of Consumption Request Queue | Current size of the consumption request queue | - | INT | AVG | |
maxConsumeRequestQueueSize | Max. Size of Consumption Request Queue | Maximum size of the consumption request queue | - | INT | MAX | |
currentConsumingThreadCount | Current Consumption Threads | Current number of consumption threads | - | INT | AVG | |
maxConsumingPoolSize | Max. Consumption Threads | Maximum number of consumption threads | - | INT | MAX | |
Message listener monitoring (consumeListener: APM counts message consumption statistics by MessageListener.) | consumeListener | MessageListener | Registered message listener, which is the callback function for message consumption | - | ENUM | LAST |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent consumption | - | INT | MAX | |
errorCount | Errors | Number of message consumption errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of consumption call times | - | INT | SUM | |
consumedMsgCount | Messages Consumed | Number of messages that have been consumed | - | INT | SUM | |
consumedBytes | Bytes Consumed | Number of bytes that have been consumed | - | INT | SUM | |
reconsumeTimes | Message Re-consumption Times | Number of message re-consumption times | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message consumption | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for consuming messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being consumed at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for consuming messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent consumption | - | INT | MAX | |
errorCount | Errors | Number of message consumption errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of consumption call times | - | INT | SUM | |
consumedMsgCount | Messages Consumed | Number of messages that have been consumed | - | INT | SUM | |
consumedBytes | Bytes Consumed | Number of bytes that have been consumed | - | INT | SUM | |
reconsumeTimes | Message re-consumption times | Number of message re-consumption times | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message consumption | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for consuming messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being consumed at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for consuming messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
topic | Topic | Topic for message consumption | - | ENUM | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent consumption | - | INT | MAX | |
errorCount | Errors | Number of message consumption errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of consumption call times | - | INT | SUM | |
consumedMsgCount | Messages Consumed | Number of messages that have been consumed | - | INT | SUM | |
consumedBytes | Bytes Consumed | Number of bytes that have been consumed | - | INT | SUM | |
reconsumeTimes | Message Re-consumption Times | Number of message re-consumption times | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message consumption | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for consuming messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being consumed at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for consuming messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
queue | Message Queue | Message queue ID | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent consumption | - | INT | MAX | |
errorCount | Errors | Number of message consumption errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of consumption call times | - | INT | SUM | |
consumedMsgCount | Messages Consumed | Number of messages that have been consumed | - | INT | SUM | |
consumedBytes | Bytes Consumed | Number of bytes that have been consumed | - | INT | SUM | |
reconsumeTimes | Message Re-consumption Times | Number of message re-consumption times | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message consumption | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for consuming messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being pulled at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for pulling messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent pulling | - | INT | MAX | |
errorCount | Errors | Number of message pull errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of pull calls | - | INT | SUM | |
pulledMsgCount | Messages Pulled | Number of messages that have been pulled | - | INT | SUM | |
pulledBytes | Bytes Pulled | Number of bytes that have been pulled | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message pulling | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for pulling messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being pulled at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for pulling messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | Number of requests with response time longer than 10s | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
topic | Topic | Topic for pulling messages | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent pulling | - | INT | MAX | |
errorCount | Errors | Number of message pull errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of pull calls | - | INT | SUM | |
pulledMsgCount | Messages Pulled | Number of messages that have been pulled | - | INT | SUM | |
pulledBytes | Bytes Pulled | Number of bytes that have been pulled | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message pulling | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for pulling messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being pulled at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for pulling messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | 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 | Consumer Group | Consumer group | - | ENUM | LAST | |
queue | Message Queue | Message queue ID | - | ENUM | LAST | |
pid | pid | PID | - | STRING | LAST | |
concurrentMax | Max. Concurrency | Maximum number of messages for concurrent pulling | - | INT | MAX | |
errorCount | Errors | Number of message pull errors | - | INT | SUM | |
errorTraceId | Error Trace ID | ID of the trace that encounters an error in a collection period | - | STRING | LAST | |
invokeCount | invokeCount | Number of pull calls | - | INT | SUM | |
pulledMsgCount | Messages Pulled | Number of messages that have been pulled | - | INT | SUM | |
pulledBytes | Bytes Pulled | Number of bytes that have been pulled | - | INT | SUM | |
lastError | Error Message | Information about the error that has occurred during message pulling | - | STRING | LAST | |
maxTime | Max. RT | Maximum response time for pulling messages | - | INT | MAX | |
runningCount | Ongoing Executions | Number of messages that are being pulled at the time of collection | - | INT | SUM | |
slowTraceId | Slow Trace ID | ID of the slowest trace in a collection period | - | STRING | LAST | |
totalTime | Total RT | Total response time for pulling messages | - | INT | SUM | |
range1 | 0–10 ms | Number of requests with 0–10 ms response time | - | INT | SUM | |
range2 | 10–100 ms | Number of requests with 10–100 ms response time | - | INT | SUM | |
range3 | 100–200 ms | Number of requests with 100–200 ms response time | - | INT | SUM | |
range4 | 200–1000 ms | Number of requests with 200–1000 ms response time | - | INT | SUM | |
range5 | 1–10s | Number of requests with 1–10s response time | - | INT | SUM | |
range6 | > 10s | Number of requests with response time longer than 10s | - | INT | SUM | |
Total monitoring (total: APM counts message consumption statistics by client.) | consumeErrorCount | Consumption Errors | 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 | Bytes Consumed | Number of bytes that have been consumed | - | INT | SUM | |
consumeTotalTime | Total RT for Message Consumption | Total response time for consuming messages | - | INT | SUM | |
reconsumeTimes | Message Re-consumption Times | Number of message re-consumption times | - | INT | SUM | |
pullErrorCount | Pull Errors | 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 | Bytes Pulled | Number of bytes that have been pulled | - | INT | SUM | |
pullTotalTime | Total Pull RT | Total response time for pulling messages | - | INT | SUM |