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(). |
Proposed Changes
TODOAs we want this metric to measure the time that the user takes to call poll() , we will store a long lastPollMs in KafkaConsumer. We will calculate the elapsed time (and update lastPollMs on every call to poll.
Compatibility, Deprecation, and Migration Plan
As this KIP simply adds new metrics, there is no issue regarding compatibility, deprecation, or migration plan.
Rejected Alternatives
None at the moment.