diff options
| author | Mark Roberts <markroberts@kixeye.com> | 2014-03-18 20:19:25 -0700 |
|---|---|---|
| committer | Mark Roberts <markroberts@kixeye.com> | 2014-03-18 20:19:25 -0700 |
| commit | a6fc260f288ac639070783a0f6faa94bd7612c67 (patch) | |
| tree | 8c123df8e2f5c3afab5184f0d6d6f2f9ba8f5aa8 /kafka/client.py | |
| parent | 888f206d5417e95f26de407b28fe935950aea2c9 (diff) | |
| parent | 9599215bf28b65a29908b8644dcaa6f3614a425d (diff) | |
| download | kafka-python-a6fc260f288ac639070783a0f6faa94bd7612c67.tar.gz | |
Merge branch 'master' into conn_refactor
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 12452de..29ee69b 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -83,14 +83,14 @@ class KafkaClient(object): brokers. Keep trying until you succeed. """ for (host, port) in self.hosts: - conn = self._get_conn(host, port) try: + conn = self._get_conn(host, port) conn.send(requestId, request) response = conn.recv(requestId) return response except Exception, e: - log.warning("Could not send request [%r] to server %s, " - "trying next server: %s" % (request, conn, e)) + log.warning("Could not send request [%r] to server %s:%i, " + "trying next server: %s" % (request, host, port, e)) continue raise KafkaUnavailableError("All servers failed to process request") |