summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorVetoshkin Nikita <nekto0n@yandex-team.ru>2013-10-03 18:06:28 +0400
committerDavid Arthur <mumrah@gmail.com>2013-10-03 19:37:14 -0400
commit8b05e6240bfce76868d2126aad75b78af1a17c60 (patch)
tree2ba9b25aba6fa4866545667183555f8e84dd55eb /kafka/client.py
parente392e0c2010562c10eca210056edef057e344e30 (diff)
downloadkafka-python-8b05e6240bfce76868d2126aad75b78af1a17c60.tar.gz
style: fix camelCase variable names
Conflicts: kafka/util.py
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/client.py b/kafka/client.py
index 5fb3842..2fdb271 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -61,11 +61,11 @@ class KafkaClient(object):
Discover brokers and metadata for a set of topics. This method will
recurse in the event of a retry.
"""
- requestId = self._next_id()
+ request_id = self._next_id()
request = KafkaProtocol.encode_metadata_request(self.client_id,
- requestId, topics)
+ request_id, topics)
- response = self._send_broker_unaware_request(requestId, request)
+ response = self._send_broker_unaware_request(request_id, request)
if response is None:
raise Exception("All servers failed to process request")