diff options
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 764cbf6..7798a75 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -72,9 +72,9 @@ class KafkaConnection(local): # TODO multiplex socket communication to allow for multi-threaded clients - def send(self, requestId, payload): + def send(self, request_id, payload): "Send a request to Kafka" - 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)) sent = self._sock.sendall(payload) if sent != None: raise RuntimeError("Kafka went away") |