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 has 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 |
|
MessageListener 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 |
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot