How to debug ZooKeeper connection inside a Python script

Debug ZooKeeper connection inside a Python script.

Create zookeeper_debug_example.py Python script.

#!/usr/bin/env python3

import argparse
import logging
import os.path

from kazoo.client import KazooClient


class ApplicationNode(object):

    def __init__(self, path, zookeeper_hosts):
        self.zookeeper = KazooClient(hosts=zookeeper_hosts)
        self.path = path
        self.connect()
        self.get(path)

    def connect(self):
        self.zookeeper.start()

    def get(self, path):
        children = self.zookeeper.get_children(path)
        if len(children) == :
            data, stat = self.zookeeper.get(path)
            print("Path: %s\nStat: %s\nData: %s\n" % (path, stat, data))
        else:
            print("%s children in %s: %s\n" % (len(children), path, children))
            for c in children:
                children_path = os.path.join(path, c)
                if self.zookeeper.exists(children_path):
                    self.get(children_path)


if __name__ == ';__main__';:
    parser = argparse.ArgumentParser(description=';ZooKeeper example debug application';)
    parser.add_argument(';--path';)
    parser.add_argument(';--zookeeper';)
    parser.add_argument(';--debug';, type=bool, default=False)

    args = parser.parse_args()

    if args.debug:
        logging.basicConfig(format=';%(asctime)s - %(levelname)-10s - %(message)s';,
                            level=logging.DEBUG,
                            datefmt=';%d-%m-%Y %H:%M:%S';)

    ApplicationNode(path=args.path, zookeeper_hosts=args.zookeeper)

Recursively list files located in a specific path.

$ python3 zookeeper_debug_example.py --zookeeper 172.16.0.101:2181 --path /brokers 

3 children in /brokers: ['ids', 'topics', 'seqid']

5 children in /brokers/ids: ['1', '2', '3', '4', '5']

Path: /brokers/ids/1
Stat: ZnodeStat(czxid=12884901896, mzxid=12884901896, ctime=1624862505047, mtime=1624862505047, version=1, cversion=0, aversion=0, ephemeralOwner=72060994600370176, dataLength=220, numChildren=0, pzxid=12884901896)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka1.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka1.example.org","version":5,"timestamp":"1624862505032"}'

Path: /brokers/ids/2
Stat: ZnodeStat(czxid=12884901914, mzxid=12884901914, ctime=1624862505513, mtime=1624862505513, version=1, cversion=0, aversion=0, ephemeralOwner=144118582778003456, dataLength=220, numChildren=0, pzxid=12884901914)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka2.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka2.example.org","version":5,"timestamp":"1624862505507"}'

Path: /brokers/ids/3
Stat: ZnodeStat(czxid=12884901893, mzxid=12884901893, ctime=1624862504802, mtime=1624862504802, version=1, cversion=0, aversion=0, ephemeralOwner=216176170777706496, dataLength=220, numChildren=0, pzxid=12884901893)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka3.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka3.example.org","version":5,"timestamp":"1624862504763"}'

Path: /brokers/ids/4
Stat: ZnodeStat(czxid=12884901890, mzxid=12884901890, ctime=1624862504649, mtime=1624862504649, version=1, cversion=0, aversion=0, ephemeralOwner=288233760010862592, dataLength=220, numChildren=0, pzxid=12884901890)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka4.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka4.example.org","version":5,"timestamp":"1624862504601"}'

Path: /brokers/ids/5
Stat: ZnodeStat(czxid=12884901913, mzxid=12884901913, ctime=1624862505451, mtime=1624862505451, version=1, cversion=0, aversion=0, ephemeralOwner=360291349371092992, dataLength=220, numChildren=0, pzxid=12884901913)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka5.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka5.example.org","version":5,"timestamp":"1624862505410"}'

1 children in /brokers/topics: ['logs']

1 children in /brokers/topics/logs: ['partitions']

5 children in /brokers/topics/logs/partitions: ['0', '1', '2', '3', '4']

1 children in /brokers/topics/logs/partitions/0: ['state']

Path: /brokers/topics/logs/partitions/0/state
Stat: ZnodeStat(czxid=12884902042, mzxid=12884902042, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902042)
Data: b'{"controller_epoch":2,"leader":1,"version":1,"leader_epoch":0,"isr":[1]}'

1 children in /brokers/topics/logs/partitions/1: ['state']

Path: /brokers/topics/logs/partitions/1/state
Stat: ZnodeStat(czxid=12884902039, mzxid=12884902039, ctime=1624908864028, mtime=1624908864028, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902039)
Data: b'{"controller_epoch":2,"leader":2,"version":1,"leader_epoch":0,"isr":[2]}'

1 children in /brokers/topics/logs/partitions/2: ['state']

Path: /brokers/topics/logs/partitions/2/state
Stat: ZnodeStat(czxid=12884902040, mzxid=12884902040, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902040)
Data: b'{"controller_epoch":2,"leader":3,"version":1,"leader_epoch":0,"isr":[3]}'

1 children in /brokers/topics/logs/partitions/3: ['state']

Path: /brokers/topics/logs/partitions/3/state
Stat: ZnodeStat(czxid=12884902041, mzxid=12884902041, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902041)
Data: b'{"controller_epoch":2,"leader":5,"version":1,"leader_epoch":0,"isr":[5]}'

1 children in /brokers/topics/logs/partitions/4: ['state']

Path: /brokers/topics/logs/partitions/4/state
Stat: ZnodeStat(czxid=12884902038, mzxid=12884902038, ctime=1624908864026, mtime=1624908864026, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902038)
Data: b'{"controller_epoch":2,"leader":4,"version":1,"leader_epoch":0,"isr":[4]}'

Path: /brokers/seqid
Stat: ZnodeStat(czxid=4294967309, mzxid=4294967309, ctime=1624810862364, mtime=1624810862364, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=0, pzxid=4294967309)
Data: None

Recursively list files located in a specific path with debug.

$ python3 zookeeper_debug_example.py --zookeeper 172.16.0.101:2181 --path /brokers --debug true

28-06-2021 21:34:56 - INFO       - Connecting to 172.16.0.101(172.16.0.101):2181, use_ssl: False
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=10000, session_id=0, passwd=b'\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None)
28-06-2021 21:34:56 - INFO       - Zookeeper connection established, state: CONNECTED
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=1): GetChildren(path='/brokers', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=1): ['ids', 'topics', 'seqid']
3 children in /brokers: ['ids', 'topics', 'seqid']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=2): Exists(path='/brokers/ids', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=2): ZnodeStat(czxid=4294967301, mzxid=4294967301, ctime=1624810862324, mtime=1624810862324, version=0, cversion=15, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=5, pzxid=12884901914)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=3): GetChildren(path='/brokers/ids', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=3): ['1', '2', '3', '4', '5']
5 children in /brokers/ids: ['1', '2', '3', '4', '5']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=4): Exists(path='/brokers/ids/1', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=4): ZnodeStat(czxid=12884901896, mzxid=12884901896, ctime=1624862505047, mtime=1624862505047, version=1, cversion=0, aversion=0, ephemeralOwner=72060994600370176, dataLength=220, numChildren=0, pzxid=12884901896)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=5): GetChildren(path='/brokers/ids/1', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=5): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=6): GetData(path='/brokers/ids/1', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=6): (b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka1.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka1.example.org","version":5,"timestamp":"1624862505032"}', ZnodeStat(czxid=12884901896, mzxid=12884901896, ctime=1624862505047, mtime=1624862505047, version=1, cversion=0, aversion=0, ephemeralOwner=72060994600370176, dataLength=220, numChildren=0, pzxid=12884901896))
Path: /brokers/ids/1
Stat: ZnodeStat(czxid=12884901896, mzxid=12884901896, ctime=1624862505047, mtime=1624862505047, version=1, cversion=0, aversion=0, ephemeralOwner=72060994600370176, dataLength=220, numChildren=0, pzxid=12884901896)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka1.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka1.example.org","version":5,"timestamp":"1624862505032"}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=7): Exists(path='/brokers/ids/2', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=7): ZnodeStat(czxid=12884901914, mzxid=12884901914, ctime=1624862505513, mtime=1624862505513, version=1, cversion=0, aversion=0, ephemeralOwner=144118582778003456, dataLength=220, numChildren=0, pzxid=12884901914)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=8): GetChildren(path='/brokers/ids/2', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=8): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=9): GetData(path='/brokers/ids/2', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=9): (b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka2.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka2.example.org","version":5,"timestamp":"1624862505507"}', ZnodeStat(czxid=12884901914, mzxid=12884901914, ctime=1624862505513, mtime=1624862505513, version=1, cversion=0, aversion=0, ephemeralOwner=144118582778003456, dataLength=220, numChildren=0, pzxid=12884901914))
Path: /brokers/ids/2
Stat: ZnodeStat(czxid=12884901914, mzxid=12884901914, ctime=1624862505513, mtime=1624862505513, version=1, cversion=0, aversion=0, ephemeralOwner=144118582778003456, dataLength=220, numChildren=0, pzxid=12884901914)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka2.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka2.example.org","version":5,"timestamp":"1624862505507"}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=10): Exists(path='/brokers/ids/3', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=10): ZnodeStat(czxid=12884901893, mzxid=12884901893, ctime=1624862504802, mtime=1624862504802, version=1, cversion=0, aversion=0, ephemeralOwner=216176170777706496, dataLength=220, numChildren=0, pzxid=12884901893)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=11): GetChildren(path='/brokers/ids/3', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=11): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=12): GetData(path='/brokers/ids/3', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=12): (b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka3.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka3.example.org","version":5,"timestamp":"1624862504763"}', ZnodeStat(czxid=12884901893, mzxid=12884901893, ctime=1624862504802, mtime=1624862504802, version=1, cversion=0, aversion=0, ephemeralOwner=216176170777706496, dataLength=220, numChildren=0, pzxid=12884901893))
Path: /brokers/ids/3
Stat: ZnodeStat(czxid=12884901893, mzxid=12884901893, ctime=1624862504802, mtime=1624862504802, version=1, cversion=0, aversion=0, ephemeralOwner=216176170777706496, dataLength=220, numChildren=0, pzxid=12884901893)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka3.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka3.example.org","version":5,"timestamp":"1624862504763"}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=13): Exists(path='/brokers/ids/4', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=13): ZnodeStat(czxid=12884901890, mzxid=12884901890, ctime=1624862504649, mtime=1624862504649, version=1, cversion=0, aversion=0, ephemeralOwner=288233760010862592, dataLength=220, numChildren=0, pzxid=12884901890)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=14): GetChildren(path='/brokers/ids/4', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=14): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=15): GetData(path='/brokers/ids/4', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=15): (b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka4.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka4.example.org","version":5,"timestamp":"1624862504601"}', ZnodeStat(czxid=12884901890, mzxid=12884901890, ctime=1624862504649, mtime=1624862504649, version=1, cversion=0, aversion=0, ephemeralOwner=288233760010862592, dataLength=220, numChildren=0, pzxid=12884901890))
Path: /brokers/ids/4
Stat: ZnodeStat(czxid=12884901890, mzxid=12884901890, ctime=1624862504649, mtime=1624862504649, version=1, cversion=0, aversion=0, ephemeralOwner=288233760010862592, dataLength=220, numChildren=0, pzxid=12884901890)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka4.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka4.example.org","version":5,"timestamp":"1624862504601"}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=16): Exists(path='/brokers/ids/5', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=16): ZnodeStat(czxid=12884901913, mzxid=12884901913, ctime=1624862505451, mtime=1624862505451, version=1, cversion=0, aversion=0, ephemeralOwner=360291349371092992, dataLength=220, numChildren=0, pzxid=12884901913)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=17): GetChildren(path='/brokers/ids/5', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=17): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=18): GetData(path='/brokers/ids/5', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=18): (b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka5.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka5.example.org","version":5,"timestamp":"1624862505410"}', ZnodeStat(czxid=12884901913, mzxid=12884901913, ctime=1624862505451, mtime=1624862505451, version=1, cversion=0, aversion=0, ephemeralOwner=360291349371092992, dataLength=220, numChildren=0, pzxid=12884901913))
Path: /brokers/ids/5
Stat: ZnodeStat(czxid=12884901913, mzxid=12884901913, ctime=1624862505451, mtime=1624862505451, version=1, cversion=0, aversion=0, ephemeralOwner=360291349371092992, dataLength=220, numChildren=0, pzxid=12884901913)
Data: b'{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://kafka5.example.org:9092"],"jmx_port":-1,"port":9092,"host":"kafka5.example.org","version":5,"timestamp":"1624862505410"}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=19): Exists(path='/brokers/topics', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=19): ZnodeStat(czxid=4294967302, mzxid=4294967302, ctime=1624810862330, mtime=1624810862330, version=0, cversion=7, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902031)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=20): GetChildren(path='/brokers/topics', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=20): ['logs']
1 children in /brokers/topics: ['logs']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=21): Exists(path='/brokers/topics/logs', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=21): ZnodeStat(czxid=12884902031, mzxid=12884902031, ctime=1624908864007, mtime=1624908864007, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=148, numChildren=1, pzxid=12884902032)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=22): GetChildren(path='/brokers/topics/logs', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=22): ['partitions']
1 children in /brokers/topics/logs: ['partitions']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=23): Exists(path='/brokers/topics/logs/partitions', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=23): ZnodeStat(czxid=12884902032, mzxid=12884902032, ctime=1624908864016, mtime=1624908864016, version=0, cversion=5, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=5, pzxid=12884902037)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=24): GetChildren(path='/brokers/topics/logs/partitions', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=24): ['0', '1', '2', '3', '4']
5 children in /brokers/topics/logs/partitions: ['0', '1', '2', '3', '4']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=25): Exists(path='/brokers/topics/logs/partitions/0', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=25): ZnodeStat(czxid=12884902037, mzxid=12884902037, ctime=1624908864021, mtime=1624908864021, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902042)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=26): GetChildren(path='/brokers/topics/logs/partitions/0', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=26): ['state']
1 children in /brokers/topics/logs/partitions/0: ['state']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=27): Exists(path='/brokers/topics/logs/partitions/0/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=27): ZnodeStat(czxid=12884902042, mzxid=12884902042, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902042)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=28): GetChildren(path='/brokers/topics/logs/partitions/0/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=28): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=29): GetData(path='/brokers/topics/logs/partitions/0/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=29): (b'{"controller_epoch":2,"leader":1,"version":1,"leader_epoch":0,"isr":[1]}', ZnodeStat(czxid=12884902042, mzxid=12884902042, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902042))
Path: /brokers/topics/logs/partitions/0/state
Stat: ZnodeStat(czxid=12884902042, mzxid=12884902042, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902042)
Data: b'{"controller_epoch":2,"leader":1,"version":1,"leader_epoch":0,"isr":[1]}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=30): Exists(path='/brokers/topics/logs/partitions/1', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=30): ZnodeStat(czxid=12884902034, mzxid=12884902034, ctime=1624908864021, mtime=1624908864021, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902039)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=31): GetChildren(path='/brokers/topics/logs/partitions/1', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=31): ['state']
1 children in /brokers/topics/logs/partitions/1: ['state']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=32): Exists(path='/brokers/topics/logs/partitions/1/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=32): ZnodeStat(czxid=12884902039, mzxid=12884902039, ctime=1624908864028, mtime=1624908864028, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902039)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=33): GetChildren(path='/brokers/topics/logs/partitions/1/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=33): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=34): GetData(path='/brokers/topics/logs/partitions/1/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=34): (b'{"controller_epoch":2,"leader":2,"version":1,"leader_epoch":0,"isr":[2]}', ZnodeStat(czxid=12884902039, mzxid=12884902039, ctime=1624908864028, mtime=1624908864028, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902039))
Path: /brokers/topics/logs/partitions/1/state
Stat: ZnodeStat(czxid=12884902039, mzxid=12884902039, ctime=1624908864028, mtime=1624908864028, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902039)
Data: b'{"controller_epoch":2,"leader":2,"version":1,"leader_epoch":0,"isr":[2]}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=35): Exists(path='/brokers/topics/logs/partitions/2', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=35): ZnodeStat(czxid=12884902035, mzxid=12884902035, ctime=1624908864021, mtime=1624908864021, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902040)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=36): GetChildren(path='/brokers/topics/logs/partitions/2', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=36): ['state']
1 children in /brokers/topics/logs/partitions/2: ['state']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=37): Exists(path='/brokers/topics/logs/partitions/2/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=37): ZnodeStat(czxid=12884902040, mzxid=12884902040, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902040)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=38): GetChildren(path='/brokers/topics/logs/partitions/2/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=38): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=39): GetData(path='/brokers/topics/logs/partitions/2/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=39): (b'{"controller_epoch":2,"leader":3,"version":1,"leader_epoch":0,"isr":[3]}', ZnodeStat(czxid=12884902040, mzxid=12884902040, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902040))
Path: /brokers/topics/logs/partitions/2/state
Stat: ZnodeStat(czxid=12884902040, mzxid=12884902040, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902040)
Data: b'{"controller_epoch":2,"leader":3,"version":1,"leader_epoch":0,"isr":[3]}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=40): Exists(path='/brokers/topics/logs/partitions/3', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=40): ZnodeStat(czxid=12884902036, mzxid=12884902036, ctime=1624908864021, mtime=1624908864021, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902041)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=41): GetChildren(path='/brokers/topics/logs/partitions/3', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=41): ['state']
1 children in /brokers/topics/logs/partitions/3: ['state']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=42): Exists(path='/brokers/topics/logs/partitions/3/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=42): ZnodeStat(czxid=12884902041, mzxid=12884902041, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902041)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=43): GetChildren(path='/brokers/topics/logs/partitions/3/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=43): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=44): GetData(path='/brokers/topics/logs/partitions/3/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=44): (b'{"controller_epoch":2,"leader":5,"version":1,"leader_epoch":0,"isr":[5]}', ZnodeStat(czxid=12884902041, mzxid=12884902041, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902041))
Path: /brokers/topics/logs/partitions/3/state
Stat: ZnodeStat(czxid=12884902041, mzxid=12884902041, ctime=1624908864031, mtime=1624908864031, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902041)
Data: b'{"controller_epoch":2,"leader":5,"version":1,"leader_epoch":0,"isr":[5]}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=45): Exists(path='/brokers/topics/logs/partitions/4', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=45): ZnodeStat(czxid=12884902033, mzxid=12884902033, ctime=1624908864020, mtime=1624908864020, version=0, cversion=1, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=12884902038)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=46): GetChildren(path='/brokers/topics/logs/partitions/4', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=46): ['state']
1 children in /brokers/topics/logs/partitions/4: ['state']

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=47): Exists(path='/brokers/topics/logs/partitions/4/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=47): ZnodeStat(czxid=12884902038, mzxid=12884902038, ctime=1624908864026, mtime=1624908864026, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902038)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=48): GetChildren(path='/brokers/topics/logs/partitions/4/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=48): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=49): GetData(path='/brokers/topics/logs/partitions/4/state', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=49): (b'{"controller_epoch":2,"leader":4,"version":1,"leader_epoch":0,"isr":[4]}', ZnodeStat(czxid=12884902038, mzxid=12884902038, ctime=1624908864026, mtime=1624908864026, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902038))
Path: /brokers/topics/logs/partitions/4/state
Stat: ZnodeStat(czxid=12884902038, mzxid=12884902038, ctime=1624908864026, mtime=1624908864026, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=72, numChildren=0, pzxid=12884902038)
Data: b'{"controller_epoch":2,"leader":4,"version":1,"leader_epoch":0,"isr":[4]}'

28-06-2021 21:34:56 - DEBUG      - Sending request(xid=50): Exists(path='/brokers/seqid', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=50): ZnodeStat(czxid=4294967309, mzxid=4294967309, ctime=1624810862364, mtime=1624810862364, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=0, pzxid=4294967309)
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=51): GetChildren(path='/brokers/seqid', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=51): []
28-06-2021 21:34:56 - DEBUG      - Sending request(xid=52): GetData(path='/brokers/seqid', watcher=None)
28-06-2021 21:34:56 - DEBUG      - Received response(xid=52): (None, ZnodeStat(czxid=4294967309, mzxid=4294967309, ctime=1624810862364, mtime=1624810862364, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=0, pzxid=4294967309))
Path: /brokers/seqid
Stat: ZnodeStat(czxid=4294967309, mzxid=4294967309, ctime=1624810862364, mtime=1624810862364, version=0, cversion=0, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=0, pzxid=4294967309)
Data: None