diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 21:20:42 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-16 21:20:42 -0700 |
| commit | 5ab4d5c274112a4e2024dea415a0ec4b79009a28 (patch) | |
| tree | 2f75731a028194d92d8df916a2a6c553385aae80 /kafka/client.py | |
| parent | 2a7f4dbb8159464941afa25d49428976cc05f902 (diff) | |
| parent | 277f0ddd61c230181f5f21d427070ec44b36a257 (diff) | |
| download | kafka-python-5ab4d5c274112a4e2024dea415a0ec4b79009a28.tar.gz | |
Merge pull request #762 from dpkp/metadata_v1
Use Metadata Request/Response v1 with 0.10+ brokers
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 891ae03..8a34cc4 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -137,7 +137,7 @@ class SimpleClient(object): kafka.errors.check_error(resp) # Otherwise return the BrokerMetadata - return BrokerMetadata(resp.nodeId, resp.host, resp.port) + return BrokerMetadata(resp.nodeId, resp.host, resp.port, None) def _next_id(self): """Generate a new correlation id""" @@ -525,7 +525,7 @@ class SimpleClient(object): log.debug('Updating broker metadata: %s', resp.brokers) log.debug('Updating topic metadata: %s', [topic for _, topic, _ in resp.topics]) - self.brokers = dict([(nodeId, BrokerMetadata(nodeId, host, port)) + self.brokers = dict([(nodeId, BrokerMetadata(nodeId, host, port, None)) for nodeId, host, port in resp.brokers]) for error, topic, partitions in resp.topics: @@ -577,7 +577,7 @@ class SimpleClient(object): # (not sure how this could happen. server could be in bad state) else: self.topics_to_brokers[topic_part] = BrokerMetadata( - leader, None, None + leader, None, None, None ) def send_metadata_request(self, payloads=[], fail_on_error=True, |