THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Metric Name | Mbean Name | Description |
---|---|---|
time-between-poll-avg | kafka.consumer:type=consumer-metrics,client-id=([-.\w]+) | The average delay between invocations of poll(). |
time-between-poll-max | kafka.consumer:type=consumer-metrics,client-id=([-.\w]+) | The max delay between invocations of poll(). |
last-poll-seconds-ago | kafka.consumer:type=consumer-metrics,client-id=([-.\w]+) | The number of seconds since the last poll() invocation. |
poll-idle-ratio | kafka.consumer:type=consumer-metrics,client-id=([-.\w]+) | The fraction of time the consumer spent waiting for the user to process records from poll. |
...
On each call to poll()
, we will calculate the elapsed time since lastPollMs
, record it in the Sensor
which has Avg
& Max
, and update lastPollMs
.
last-poll-seconds-ago
The last-poll-seconds-ago
metric will measure the time since the user last called poll()
to provide more insight into how/when the user code calls poll()
.
poll-idle-ratio
There will be an additional metric that measures the idle time of the consumer in waiting for the user to process records returned from poll:
...