diff options
author | Vetoshkin Nikita <nekto0n@yandex-team.ru> | 2013-10-03 18:06:28 +0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-10-03 19:37:14 -0400 |
commit | 8b05e6240bfce76868d2126aad75b78af1a17c60 (patch) | |
tree | 2ba9b25aba6fa4866545667183555f8e84dd55eb /kafka/client.py | |
parent | e392e0c2010562c10eca210056edef057e344e30 (diff) | |
download | kafka-python-8b05e6240bfce76868d2126aad75b78af1a17c60.tar.gz |
style: fix camelCase variable names
Conflicts:
kafka/util.py
Diffstat (limited to 'kafka/client.py')
-rw-r--r-- | kafka/client.py | 6 |
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") |