Complemento Kafka

Kafka es un servicio de registros de confirmación repetidos, con particiones y distribuidos. Para obtener más información, visita kafka.apache.org.

Investigación

Incluso si el complemento de Kafka no está configurado, Cloud Monitoring descubre los servicios de Kafka que se ejecutan en tu proyecto de Google Cloud mediante lo siguiente:

  • La búsqueda de nombres de instancia para kafka
  • Las comprobaciones de puertos abiertos a 9092 a través de reglas de firewall

Los servicios descubiertos se muestran en la página de Servicios de Kafka en el menú Recursos. Después de instalar el agente de supervisión y configurar el complemento Kafka en tus instancias, Monitoring propaga la página de Servicios de Kafka con inventarios y métricas.

Configura Monitoring para supervisar Kafka

Después de instalar el agente de supervisión, sigue las siguientes instrucciones para configurar el complemento Kafka en tus instancias.

Requisitos

El complemento Kafka requiere la versión 5.5.0-257 o posterior del agente de supervisión. Para actualizar el agente, consulta Actualiza el agente.

Habilita el complemento de supervisión Kafka

Kafka se supervisa mediante JMX. Monitoring admite la supervisión de la versión 0.8.2 de Kafka y versiones posteriores.

En tu instancia de VM, descarga kafka-082.conf del repositorio de configuración de GitHub y colócalo en el directorio /opt/stackdriver/collectd/etc/collectd.d/:

(cd /opt/stackdriver/collectd/etc/collectd.d/ && sudo curl -O https://raw.githubusercontent.com/Stackdriver/stackdriver-agent-service-configs/master/etc/collectd.d/kafka-082.conf)
    

El archivo de configuración del complemento descargado supone que el servidor de Kafka está configurado para aceptar conexiones JMX en el puerto 9999. Si configuraste Kafka con un puerto JMX diferente, como raíz, edita el archivo y sigue las instrucciones para cambiar la configuración del puerto JMX.

Después de agregar el archivo de configuración, ejecuta el siguiente comando para reiniciar el agente de supervisión:

sudo service stackdriver-agent restart
    

A fin de obtener más información sobre el complemento collectd GenericJMX que se usa para supervisar Kafka, consulta Plugin:GenericJMX.

Qué se supervisa

Las listas completas de las métricas que supervisa el complemento Kafka se encuentran en las secciones métricas del agente: kafka y métricas del agente: jvm.