| Metric/Attribute name | +Mbean name | +Description | +
|---|---|---|
| TotalShareFetchRequestsPerSec | +kafka.server:type=BrokerTopicMetrics,name=TotalShareFetchRequestsPerSec,topic=([-.\w]+) | +The fetch request rate per second. | +
| FailedShareFetchRequestsPerSec | +kafka.server:type=BrokerTopicMetrics,name=FailedShareFetchRequestsPerSec,topic=([-.\w]+) | +The share fetch request rate for requests that failed. | +
| TotalShareAcknowledgementRequestsPerSec | +kafka.server:type=BrokerTopicMetrics,name=TotalShareAcknowledgementRequestsPerSec,topic=([-.\w]+) | +The acknowledgement request rate per second. | +
| FailedShareAcknowledgementRequestsPerSec | +kafka.server:type=BrokerTopicMetrics,name=FailedShareAcknowledgementRequestsPerSec,topic=([-.\w]+) | +The share acknowledgement request rate for requests that failed. | +
| RecordAcknowledgementsPerSec | +kafka.server:type=ShareGroupMetrics,name=RecordAcknowledgementsPerSec,ackType={Accept|Release|Reject|Renew} | +The rate per second of records acknowledged per acknowledgement type. | +
| PartitionLoadTimeMs | +kafka.server:type=ShareGroupMetrics,name=PartitionLoadTimeMs | +The time taken to load the share partitions. | +
| RequestTopicPartitionsFetchRatio | +kafka.server:type=ShareGroupMetrics,name=RequestTopicPartitionsFetchRatio,group=([-.\w]+) | +The ratio of topic-partitions acquired to the total number of topic-partitions in share fetch request. | +
| TopicPartitionsAcquireTimeMs | +kafka.server:type=ShareGroupMetrics,name=TopicPartitionsAcquireTimeMs,group=([-.\w]+) | +The time elapsed (in millisecond) to acquire any topic partition for fetch. | +
| AcquisitionLockTimeoutPerSec | +kafka.server:type=SharePartitionMetrics,name=AcquisitionLockTimeoutPerSec,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The rate of acquisition locks for records which are not acknowledged within the timeout. | +
| InFlightMessageCount | +kafka.server:type=SharePartitionMetrics,name=InFlightMessageCount,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The number of in-flight messages for the share partition. | +
| InFlightBatchCount | +kafka.server:type=SharePartitionMetrics,name=InFlightBatchCount,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The number of in-flight batches for the share partition. | +
| InFlightBatchMessageCount | +kafka.server:type=SharePartitionMetrics,name=InFlightBatchMessageCount,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The number of messages in the in-flight batch. | +
| FetchLockTimeMs | +kafka.server:type=SharePartitionMetrics,name=FetchLockTimeMs,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The time elapsed (in milliseconds) while a share partition is held under lock for fetching messages. | +
| FetchLockRatio | +kafka.server:type=SharePartitionMetrics,name=FetchLockRatio,group=([-.\w]+),topic=([-.\w]+),partition=([0-9]+) | +The fraction of time that share partition is held under lock. | +
| ShareSessionEvictionsPerSec | +kafka.server:type=ShareSessionCache,name=ShareSessionEvictionsPerSec | +The share session eviction rate per second. | +
| SharePartitionsCount | +kafka.server:type=ShareSessionCache,name=SharePartitionsCount | +The number of cached share partitions. | +
| ShareSessionsCount | +kafka.server:type=ShareSessionCache,name=ShareSessionsCount | +The number of cached share sessions. | +
| NumDelayedOperations (ShareFetch) | +kafka.server:type=DelayedOperationPurgatory,name=NumDelayedOperations,delayedOperation=ShareFetch | +The number of delayed operations for share fetch purgatory. | +
| PurgatorySize (ShareFetch) | +kafka.server:type=DelayedOperationPurgatory,name=PurgatorySize,delayedOperation=ShareFetch | +The number of requests waiting in the share fetch purgatory. This is high if share consumers use a large value for fetch.wait.max.ms. | +
| ExpiresPerSec | +kafka.server:type=DelayedShareFetchMetrics,name=ExpiresPerSec | +The expired delayed share fetch operation rate per second. | +
| Metric/Attribute name | +Mbean name | +Description | +
|---|---|---|
| group-count | +kafka.server:type=group-coordinator-metrics,name=group-count,protocol=share | +The total number of share groups managed by group coordinator. | +
| share-group-rebalance-rate | +kafka.server:type=group-coordinator-metrics,name=share-group-rebalance-rate | +The total number of share group rebalances. | +
| share-group-rebalance-count | +kafka.server:type=group-coordinator-metrics,name=share-group-rebalance-count | +The total number of share group rebalances. | +
| group-count | +kafka.server:type=group-coordinator-metrics,name=group-count,protocol=share | +The total number of share groups managed by group coordinator. | +
| partition-load-time-max | +kafka.server:type=share-coordinator-metrics,name=partition-load-time-max | +The maximum time taken in milliseconds to load the share-group state from the share-group state partitions. | +
| partition-load-time-avg | +kafka.server:type=share-coordinator-metrics,name=partition-load-time-avg | +The average time taken in milliseconds to load the share-group state from the share-group state partitions. | +
| thread-idle-ratio-min | +kafka.server:type=share-coordinator-metrics,name=thread-idle-ratio-min | +The minimum fraction of time the share coordinator thread is idle. | +
| thread-idle-ratio-avg | +kafka.server:type=share-coordinator-metrics,name=thread-idle-ratio-avg | +The average fraction of time the share coordinator thread is idle. | +
| write-rate | +kafka.server:type=share-coordinator-metrics,name=write-rate | +The number of share-group state write calls per second. | +
| write-total | +kafka.server:type=share-coordinator-metrics,name=write-total | +The total number of share-group state write calls. | +
| write-latency-avg | +kafka.server:type=share-coordinator-metrics,name=write-latency-avg | +The average time taken for a share-group state write call, including the time to write to the share-group state topic. | +
| write-latency-max | +kafka.server:type=share-coordinator-metrics,name=write-latency-max | +The maximum time taken for a share-group state write call, including the time to write to the share-group state topic. | +
| num-partitions | +kafka.server:type=share-coordinator-metrics,name=num-partitions,state={loading|active|failed} | +The number of partitions in the share-state topic in each state. | +
| last-pruned-offset | +kafka.server:type=share-coordinator-metrics,name=last-pruned-offset,topic=([-.\w]+),partition=([0-9]+) | +The offset at which the share-group state topic was last pruned. | +
| Metric/Attribute name | +Mbean name | +Description | +
|---|---|---|
| last-poll-seconds-ago | +kafka.consumer:type=consumer-share-metrics,name=last-poll-seconds-ago,client-id=([-.\w]+) | +The number of seconds since the last poll() invocation. | +
| time-between-poll-avg | +kafka.consumer:type=consumer-share-metrics,name=time-between-poll-avg,client-id=([-.\w]+) | +The average delay between invocations of poll() in milliseconds. | +
| time-between-poll-max | +kafka.consumer:type=consumer-share-metrics,name=time-between-poll-max,client-id=([-.\w]+) | +The maximum delay between invocations of poll() in milliseconds. | +
| poll-idle-ratio-avg | +kafka.consumer:type=consumer-share-metrics,name=poll-idle-ratio-avg,client-id=([-.\w]+) | +The average fraction of time the consumer's poll() is idle as opposed to waiting for the user code to process records. | +
| heartbeat-response-time-max | +kafka.consumer:type=consumer-share-coordinator-metrics,name=heartbeat-response-time-max,client-id=([-.\w]+) | +The maximum time taken to receive a response to a heartbeat request in milliseconds. | +
| heartbeat-rate | +kafka.consumer:type=consumer-share-coordinator-metrics,name=heartbeat-rate,client-id=([-.\w]+) | +The number of heartbeats per second. | +
| heartbeat-total | +kafka.consumer:type=consumer-share-coordinator-metrics,name=heartbeat-total,client-id=([-.\w]+) | +The total number of heartbeats. | +
| last-heartbeat-seconds-ago | +kafka.consumer:type=consumer-share-coordinator-metrics,name=last-heartbeat-seconds-ago,client-id=([-.\w]+) | +The number of seconds since the last coordinator heartbeat was sent. | +
| rebalance-total | +kafka.consumer:type=consumer-share-coordinator-metrics,name=rebalance-total,client-id=([-.\w]+) | +The total number of share group rebalances count. | +
| rebalance-rate-per-hour | +kafka.consumer:type=consumer-share-coordinator-metrics,name=rebalance-rate-per-hour,client-id=([-.\w]+) | +The number of share group rebalances event per hour. | +
| fetch-size-avg | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-size-avg,client-id=([-.\w]+) | +The average number of bytes fetched per request. | +
| fetch-size-max | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-size-max,client-id=([-.\w]+) | +The maximum number of bytes fetched per request. | +
| records-per-request-avg | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=records-per-request-avg,client-id=([-.\w]+) | +The average number of records in each request. | +
| records-per-request-max | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=records-per-request-max,client-id=([-.\w]+) | +The maximum number of records in a request. | +
| bytes-consumed-rate | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=bytes-consumed-rate,client-id=([-.\w]+) | +The average number of bytes consumed per second. | +
| bytes-consumed-total | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=bytes-consumed-total,client-id=([-.\w]+) | +The total number of bytes consumed. | +
| records-consumed-rate | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=records-consumed-rate,client-id=([-.\w]+) | +The average number of records fetched per second. | +
| records-consumed-total | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=records-consumed-total,client-id=([-.\w]+) | +The total number of records fetched. | +
| acknowledgements-send-rate | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=acknowledgements-send-rate,client-id=([-.\w]+) | +The average number of record acknowledgements sent per second. | +
| acknowledgements-send-total | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=acknowledgements-send-total,client-id=([-.\w]+) | +The total number of record acknowledgements sent. | +
| acknowledgements-error-rate | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=acknowledgements-error-rate,client-id=([-.\w]+) | +The average number of record acknowledgements that resulted in errors per second. | +
| acknowledgements-error-total | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=acknowledgements-error-total,client-id=([-.\w]+) | +The total number of record acknowledgements that resulted in errors. | +
| fetch-latency-avg | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-latency-avg,client-id=([-.\w]+) | +The average time taken for a fetch request. | +
| fetch-latency-max | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-latency-max,client-id=([-.\w]+) | +The maximum time taken for any fetch request. | +
| fetch-rate | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-rate,client-id=([-.\w]+) | +The number of fetch requests per second. | +
| fetch-total | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-total,client-id=([-.\w]+) | +The total number of fetch requests. | +
| fetch-throttle-time-avg | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-throttle-time-avg,client-id=([-.\w]+) | +The average throttle time in milliseconds. | +
| fetch-throttle-time-max | +kafka.consumer:type=consumer-share-fetch-manager-metrics,name=fetch-throttle-time-max,client-id=([-.\w]+) | +The maximum throttle time in milliseconds. | +