diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-17 17:29:54 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-17 23:22:35 -0800 |
| commit | f1ad0247df5bf6e0315ffbb1633d5979da828de0 (patch) | |
| tree | ca96d1d960a13ae481b76fd32761ea535234f02b /kafka/cluster.py | |
| parent | 799824535ceeb698152a3078f64ecbf6baca9b39 (diff) | |
| download | kafka-python-f1ad0247df5bf6e0315ffbb1633d5979da828de0.tar.gz | |
Switch BrokerConnection to (mostly) non-blocking IO.
- return kafka.Future on send()
- recv is now non-blocking call that completes futures when possible
- update KafkaClient to block on future completion
Diffstat (limited to 'kafka/cluster.py')
| -rw-r--r-- | kafka/cluster.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/cluster.py b/kafka/cluster.py index 55765dc..15921dc 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -73,7 +73,7 @@ class Cluster(object): def _bootstrap(self, hosts, timeout=2): for host, port in hosts: - conn = BrokerConnection(host, port, timeout) + conn = BrokerConnection(host, port) if not conn.connect(): continue self._brokers['bootstrap'] = conn |