Update in: 10 January 2023
:
Ver. 11-10-2022
Plugin gets metrics on producer and consumer performance.
This is ported from the Java producer and Java consumer.
Type: Server plug-in
Modules generated by the plugin
Producer
kafka-metrics-count
| count |
producer-metrics
| connection-close-rate |
| connection-creation-rate |
| select-rate |
| io-wait-time-ns-avg |
| io-wait-ratio |
| io-time-ns-avg |
| io-ratio |
| connection-count |
| network-io-rate |
| outgoing-byte-rate |
| request-rate |
| request-size-avg |
| request-size-max |
| incoming-byte-rate |
| response-rate |
| request-latency-avg |
| request-latency-max |
| bufferpool-wait-ratio |
| batch-size-avg |
| batch-size-max |
| compression-rate-avg |
| record-queue-time-avg |
| record-queue-time-max |
| produce-throttle-time-avg |
| produce-throttle-time-max |
| record-send-rate |
| records-per-request-avg |
| byte-rate |
| record-retry-rate |
| record-error-rate |
| record-size-max |
| record-size-avg |
| requests-in-flight |
| metadata-age |
producer-node-metrics.node-<node>
| outgoing-byte-rate |
| request-rate |
| request-size-avg |
| request-size-max |
| incoming-byte-rate |
| response-rate |
| request-latency-avg |
| request-latency-max |
Consumer
kafka-metrics-count
| count |
consumer-metrics
| connection-close-rate |
| connection-creation-rate |
| select-rate |
| io-wait-time-ns-avg |
| io-wait-ratio |
| io-time-ns-avg |
| io-ratio |
| connection-count |
| network-io-rate |
| outgoing-byte-rate |
| request-rate |
| request-size-avg |
| request-size-max |
| incoming-byte-rate |
| response-rate |
| request-latency-avg |
| request-latency-max |
consumer-node-metrics.node-<node>
| outgoing-byte-rate |
| request-rate |
| request-size-avg |
| request-size-max |
| incoming-byte-rate |
| response-rate |
| request-latency-avg |
| request-latency-max |
consumer-fetch-manager-metrics
| fetch-size-avg |
| fetch-size-max |
| bytes-consumed-rate |
| records-per-request-avg |
| records-consumed-rate |
| fetch-latency-avg |
| fetch-latency-max |
| fetch-rate |
| records-lag-max |
| fetch-throttle-time-avg |
| fetch-throttle-time-max |
consumer-coordinator-metrics
| heartbeat-response-time-max |
| heartbeat-rate |
| join-time-avg |
| join-time-max |
| join-rate |
| sync-time-avg |
| sync-time-max |
| sync-rate |
| last-heartbeat-seconds-ago |
| commit-latency-avg |
| commit-latency-max |
| commit-rate |
| assigned-partitions |
Others
|
topics
|
Gets all topics that the user is authorized to view. This will always issue a remote call to the cluster to get the latest information. |
|
bootstrap_connected
|
Returns True if the bootstrap is connected. |
|
subscriptions
|
Obtain subscription to the current topic. |
|
list_consumer_groups
|
List all consumer groups known to the group. |
|
least_loaded_node
|
It chooses the node with the fewest pending requests, with fallbacks. |
|
in_flight_request_count
|
Flight request count. |
Documentation
Only enterprise users can view the download links.
(Visited 341 times, 1 visits today)


