diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-08-15 12:59:35 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-08-15 12:59:35 -0700 |
| commit | cbc6fdc4b973a6a94953c9ce9c33e54e415e45bf (patch) | |
| tree | 984f25de6693e0b5354c801a4a3590bfcb760577 /kafka/producer/sender.py | |
| parent | 497ded919356038d57e935850346ff347b8ea6ef (diff) | |
| download | kafka-python-cbc6fdc4b973a6a94953c9ce9c33e54e415e45bf.tar.gz | |
Drop unused sleep kwarg to poll (#1177)
Diffstat (limited to 'kafka/producer/sender.py')
| -rw-r--r-- | kafka/producer/sender.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py index 2974faf..ad59050 100644 --- a/kafka/producer/sender.py +++ b/kafka/producer/sender.py @@ -156,7 +156,7 @@ class Sender(threading.Thread): # difference between now and its linger expiry time; otherwise the # select time will be the time difference between now and the # metadata expiry time - self._client.poll(poll_timeout_ms, sleep=True) + self._client.poll(poll_timeout_ms) def initiate_close(self): """Start closing the sender (won't complete until all data is sent).""" |