diff --git a/kazoo/client.py b/kazoo/client.py index 27b7c384..a990319c 100644 --- a/kazoo/client.py +++ b/kazoo/client.py @@ -769,7 +769,10 @@ def command(self, cmd=b"ruok"): verify_certs=self.verify_certs, ) sock.sendall(cmd) - result = sock.recv(8192) + result = b"" + temp = sock.recv(8192) + while temp: + result += temp sock.close() return result.decode("utf-8", "replace")