diff options
| author | Vetoshkin Nikita <nekto0n@yandex-team.ru> | 2013-10-03 18:13:34 +0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-10-03 19:37:14 -0400 |
| commit | 3ba54c6e05a3f77af0c38eff03c6ba58066becc1 (patch) | |
| tree | a50ae1de1bf081d0c2d1a3292f34e684dcf2687a /kafka/conn.py | |
| parent | e82f04e3b8828169b375aa51699874e69e022888 (diff) | |
| download | kafka-python-3ba54c6e05a3f77af0c38eff03c6ba58066becc1.tar.gz | |
style: fix camelCase variable names again
Diffstat (limited to 'kafka/conn.py')
| -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") |