Share Consumer Metrics

Client metrics

The following client metrics are available for monitoring share consumer applications.

Share consumer metrics

These metrics track the overall performance and behavior of share consumer clients.

last-poll-seconds-ago

MBean: kafka.consumer:type=consumer-share-metrics,client-id=([-.w]+),name=last-poll-seconds-ago: The number of seconds since the last poll() invocation.

time-between-poll-avg

MBean: kafka.consumer:type=consumer-share-metrics,client-id=([-.w]+),name=time-between-poll-avg: The average delay between invocations of poll() in milliseconds.

time-between-poll-max

MBean: kafka.consumer:type=consumer-share-metrics,client-id=([-.w]+),name=time-between-poll-max: The maximum delay between invocations of poll() in milliseconds.

poll-idle-ratio-avg

MBean: kafka.consumer:type=consumer-share-metrics,client-id=([-.w]+),name=poll-idle-ratio-avg: The average fraction of time the consumer’s poll() is idle as opposed to waiting for user code to process records.

Share fetch manager metrics

These metrics track fetch operations, record consumption, and acknowledgements for share consumers.

fetch-size-avg

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-size-avg: The average number of bytes fetched per request.

fetch-size-max

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-size-max: The maximum number of bytes fetched per request.

bytes-consumed-rate

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=bytes-consumed-rate: The average number of bytes fetched per second.

bytes-consumed-total

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=bytes-consumed-total: The total number of bytes fetched.

records-per-request-avg

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=records-per-request-avg: The average number of records in each request. When set to batch_optimized (default), this value may exceed max.poll.records to align with batch boundaries. When share.acquire.mode is set to record_limit, this value will not exceed max.poll.records.

records-per-request-max

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=records-per-request-max: The maximum number of records in a request. When set to batch_optimized (default), this value may exceed max.poll.records to align with batch boundaries. When share.acquire.mode is set to record_limit, this value will not exceed max.poll.records.

records-consumed-rate

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=records-consumed-rate: The average number of records fetched per second.

records-consumed-total

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=records-consumed-total: The total number of records fetched.

acknowledgements-send-rate

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=acknowledgements-send-rate: The average number of record acknowledgements sent per second.

acknowledgements-send-total

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=acknowledgements-send-total: The total number of record acknowledgements sent.

acknowledgements-error-rate

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=acknowledgements-error-rate: The average number of record acknowledgements that resulted in errors per second.

acknowledgements-error-total

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=acknowledgements-error-total: The total number of record acknowledgements that resulted in errors.

fetch-latency-avg

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-latency-avg: The average time taken for a fetch request in milliseconds.

fetch-latency-max

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-latency-max: The maximum time taken for any fetch request in milliseconds.

fetch-rate

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-rate: The number of fetch requests per second.

fetch-total

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-total: The total number of fetch requests.

fetch-throttle-time-avg

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-throttle-time-avg: The average throttle time in milliseconds.

fetch-throttle-time-max

MBean: kafka.consumer:type=consumer-share-fetch-manager-metrics,client-id=([-.w]+),name=fetch-throttle-time-max: The maximum throttle time in milliseconds.