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 225 times, 1 visits today)