¿Cómo comprobar el estado o los detalles del servidor Kafka?

Solución:

Si está buscando el estado del agente del clúster de Kafka, puede usar zookeeper cli para encontrar los detalles de cada agente como se indica a continuación:

ls /brokers/ids devuelve la lista de ID de intermediarios activos en el clúster.

get /brokers/ids/<id> devuelve los detalles del corredor con la identificación dada.

Ejemplo :

kafka_2.12-1.1.1 % ./bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids
Connecting to localhost:2181

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[0]

kafka_2.12-1.1.1 % ./bin/zookeeper-shell.sh localhost:2181 get /brokers/ids/0
Connecting to localhost:2181

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://localhost:9092"],"jmx_port":-1,"host":"localhost","timestamp":"1558428038778","port":9092,"version":4}
cZxid = 0x116
ctime = Tue May 21 08:40:38 UTC 2019
mZxid = 0x116
mtime = Tue May 21 08:40:38 UTC 2019
pZxid = 0x116
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x16ad9830f16000b
dataLength = 188
numChildren = 0

Puede poner estos pasos en algún script de shell para obtener los detalles de todos los corredores.

---

---

Utiliza Nuestro Buscador