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 e82f04e commit 3ba54c6Copy full SHA for 3ba54c6
kafka/conn.py
@@ -72,9 +72,9 @@ def _consume_response_iter(self):
72
73
# TODO multiplex socket communication to allow for multi-threaded clients
74
75
- def send(self, requestId, payload):
+ def send(self, request_id, payload):
76
"Send a request to Kafka"
77
- log.debug("About to send %d bytes to Kafka, request %d" % (len(payload), requestId))
+ log.debug("About to send %d bytes to Kafka, request %d" % (len(payload), request_id))
78
sent = self._sock.sendall(payload)
79
if sent != None:
80
raise RuntimeError("Kafka went away")
0 commit comments