diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-08 08:01:48 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-03-08 08:01:48 -0800 |
| commit | 8c0792581d8a38822c01b40f5d3926c659b0c439 (patch) | |
| tree | 8b39433a185984b71984a9301d3ed991bdf0fbe3 /example.py | |
| parent | 7a99013668b798aaa0acffcf382a7e48e7bd41c1 (diff) | |
| download | kafka-python-8c0792581d8a38822c01b40f5d3926c659b0c439.tar.gz | |
Do network connections and writes in KafkaClient.poll() (#1729)
* Add BrokerConnection.send_pending_requests to support async network sends
* Send network requests during KafkaClient.poll() rather than in KafkaClient.send()
* Dont acquire lock during KafkaClient.send if node is connected / ready
* Move all network connection IO into KafkaClient.poll()
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions