Módulos generados por el plugin

Agentes

El plugin crea un agente por cada elemento de --bootstrap_servers.

El nombre y el alias siguen este formato:

<agent_prefix><host:port>

Por ejemplo, con --agent_prefix KAFKA_ y el broker kafka1:9092, el agente generado será:

KAFKA_kafka1:9092

Los agentes se generan con un intervalo de 300 segundos y con la descripción Created by plugin.

Módulos

El plugin recorre todas las métricas devueltas por producer.metrics() y consumer.metrics(). Por ello, la lista exacta puede variar según la versión de kafka-python, la versión de Kafka, los nodos disponibles y la actividad del cliente.

Todos los módulos se crean con el tipo generic_data, sin unidad ni descripción. El nombre sigue este formato:

<module_prefix><metric_group>.<metric_name>

Los valores no numéricos válidos NaN e infinitos se convierten en 0.0.

Los principales grupos de métricas generados son los siguientes:

Origen Grupo de métricas Ejemplos de módulos sin prefijo Tipo
Productor y consumidor kafka-metrics kafka-metrics.count generic_data
Productor producer-metrics producer-metrics.connection-count, producer-metrics.request-rate, producer-metrics.request-latency-avg, producer-metrics.record-send-rate, producer-metrics.record-error-rate generic_data
Productor producer-node-metrics.node-<node> producer-node-metrics.node-<node>.outgoing-byte-rate, producer-node-metrics.node-<node>.request-rate, producer-node-metrics.node-<node>.response-rate generic_data
Consumidor consumer-metrics consumer-metrics.connection-count, consumer-metrics.request-rate, consumer-metrics.request-latency-avg, consumer-metrics.incoming-byte-rate generic_data
Consumidor consumer-node-metrics.node-<node> consumer-node-metrics.node-<node>.incoming-byte-rate, consumer-node-metrics.node-<node>.request-rate, consumer-node-metrics.node-<node>.response-rate generic_data
Consumidor consumer-fetch-manager-metrics consumer-fetch-manager-metrics.fetch-size-avg, consumer-fetch-manager-metrics.bytes-consumed-rate, consumer-fetch-manager-metrics.records-consumed-rate, consumer-fetch-manager-metrics.records-lag-max generic_data
Consumidor consumer-coordinator-metrics consumer-coordinator-metrics.heartbeat-rate, consumer-coordinator-metrics.join-rate, consumer-coordinator-metrics.commit-rate, consumer-coordinator-metrics.assigned-partitions generic_data

Si se utiliza --module_prefix METRIC_, por ejemplo, el módulo producer-metrics.request-rate se creará como:

METRIC_producer-metrics.request-rate

Revision #9
Created 11 October 2022 13:44:51
Updated 28 August 2026 10:29:42 by jonathan.leon