We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8b05e62 commit 3a56dfdCopy full SHA for 3a56dfd
kafka/conn.py
@@ -53,12 +53,12 @@ def _consume_response_iter(self):
53
raise Exception("Got no response from Kafka")
54
(size,) = struct.unpack('>i', resp)
55
56
- messageSize = size - 4
57
- log.debug("About to read %d bytes from Kafka", messageSize)
+ messagesize = size - 4
+ log.debug("About to read %d bytes from Kafka", messagesize)
58
59
# Read the remainder of the response
60
total = 0
61
- while total < messageSize:
+ while total < messagesize:
62
resp = self._sock.recv(self.bufsize)
63
log.debug("Read %d bytes from Kafka", len(resp))
64
if resp == "":
0 commit comments