Modules generated by the plugin
The plugin will create an agent with a customizable name with the --agent_alias parameter or with the default "Kafka" name that will contain all the modules of the execution.
Módules
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 |
Otros
|
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 bootstrap is connected.
|
|
subscriptions
|
Get the subscription to the current topic.
|
|
list_consumer_groups
|
List all consumer groups known to the pool.
|
|
least_loaded_node
|
Choose the node with the least pending requests, with fallbacks.
|
|
in_flight_request_count
|
Flight request count.
|
Example with some modules to illustrate how they would look in the agent
