diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-12-02 14:21:13 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-12-02 14:21:13 -0800 |
| commit | 58e2ab41a76518c433d7375a24191018b85ced85 (patch) | |
| tree | 4d1fdb80c101bdc2ed0b333ea75d81ddb4fba67c /kafka/conn.py | |
| parent | cdcaea6f944df10941522ebcb08946bf34c357db (diff) | |
| parent | c2adeeab057b825c8cccae67aac822be02293211 (diff) | |
| download | kafka-python-58e2ab41a76518c433d7375a24191018b85ced85.tar.gz | |
Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests
Use unblocking io for broker aware requests
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index e6a1f74..9514e48 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -118,6 +118,11 @@ class KafkaConnection(local): # TODO multiplex socket communication to allow for multi-threaded clients + def get_connected_socket(self): + if not self._sock: + self.reinit() + return self._sock + def send(self, request_id, payload): """ Send a request to Kafka |