Seguimos con los posts sobre kafka:

  1. ¿Qué es Apache Kafka?
  2. Cómo instalar y configurar el Oracle Java Development Kit.
  3. Cómo instalar y configurar en modo clúster el Apache Zookeeper.
  4. Cómo instalar y configurar en modo clúster el Apache Kafka.
  5. Operaciones habituales en Apache Zookeeper.
  6. Operaciones habituales en Apache Kafka.
  7. Cómo monitorizar Zookeeper desde el PRTG.
  8. Cómo monitorizar Apache Kafka con el PRTG.
  9. Mejoras de rendiemiento en Apache Kafka y valores óptimos de los sensores.
  10. Problemas frecuentes en la instalación, configuración y uso de un clúster Kafka.

Todos los ficheros de configuración de esta serie de posts estan publicados en gitlab.

La interacción con zookeeper es muy sencilla. Básicamente usa un código de 4 letras (four letter words) y todas las operaciones que se pueden hacer son estas:

conf
cons
crst
dump
envi
ruok
srst
srvr
stat
wchs
wchc
dirs
wchp
mntr
isro
gtmk
stmk

Ninguna de ellas permite que se le pase parámetro alguno. La descripción de las funcionalidades de cada instrucción es muy sencilla y está explicada a continuación.

conf
Muestra detalles sobre la configuración de la instancia a la que estamos conectados

cons
Muestra los detalles de las conexiones/sesiones de todos los clientes conectados a la instancia en cuestión. Incluye información sobre número de paquetes enviados/recibidos, id’s de sesión, latencias última opración realizada, etc…

crst
Resetea las estadísticas de sesión/conexión para todas las conexiones

dump
Sólo funciona en el nodo leader. Muestra información variada sobre las sesiones.

envi
Muestra información sobre el entorno en el que se ejecuta la instancia

ruok
Are you ok? Envía una petición de test al zookeeper. Que la contestación sea imok no implica que el nodo esté funcionando correctamente dentro del clúster, sencillamente que está en marcha y funcionando en el puerto indicado.

srst
Resetea las estadísticas del servidor

srvr
Muestra un listado de los detalles del servidor

stat
Muestra un listado resumido de la instancia servidor y/o clientes conectados.

wchs
Muestra información resumida sobre los watches del servidor.

wchc
Igual que la anterior pero por sesión. No usar a menos que se sepa lo que se está haciendo ya que puede tener un impacto importante en coste computacional.

dirs
Muestra los tamaños de los ficheros de snapshot y de log, en bytes.

wchp
Igual que wchc pero por path (watch) en lugar de por sesión.

mntr
Muestra un listado de parámetros y su valor que se pueden usar para monitorizar el servidor. Esta opción es la que usamos en el monitor para PRTG que hicimos en Python. Los parámetros que muestra son:

zk_version
zk_avg_latency
zk_max_latency
zk_min_latency
zk_packets_received
zk_packets_sent
zk_outstanding_requests
zk_server_state leader
zk_znode_count
zk_watch_count
zk_ephemerals_count
zk_approximate_data_size

En el nodo leader además muestra :

zk_followers
zk_synced_followers
zk_pending_syncs
zk_open_file_descriptor_count
zk_max_file_descriptor_count

isro
Comprueba si el servidor está funcionando en modo read only

Publicado por joancampsmorey

Deja un comentario