1 Star2 Stars3 Stars4 Stars5 Stars (1 votes, average: 1.00 out of 5)
Loading...

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

ES:  Kafka ES
EN:  Kafka EN

Only enterprise users can view the download links.

(Visited 165 times, 1 visits today)

For correct visualization of the Pandora FMS library extension, you must have installed version NG 760 or superior

X