def METHOD_NAME(self):
    completed_proc = subprocess.run("/kafka/bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids", shell=True,
                                    universal_newlines=True, stdout=PIPE)
    assert "[0]" in completed_proc.stdout, "kafka is not running"