Updated on 2024-07-04 GMT+08:00

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

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