diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-03-09 09:01:25 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-03-09 09:01:25 -0800 |
| commit | 11cf12ff531919e9ade2d7ebf55e9f0f6a1592da (patch) | |
| tree | d52d3db4ecb857775d22f36ca52a8031460994ac | |
| parent | 45cb3220c7394c0c285382378ef01ba4fb650317 (diff) | |
| parent | 00d527f480299cc3c0298f3e4699c2f421d3fc64 (diff) | |
| download | kafka-python-11cf12ff531919e9ade2d7ebf55e9f0f6a1592da.tar.gz | |
Merge pull request #567 from twm/patch-1
Silence suprious warnings
| -rw-r--r-- | kafka/producer/base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 9720390..2067c7e 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -471,5 +471,5 @@ class Producer(object): self.stopped = True def __del__(self): - if not self.stopped: + if self.async and not self.stopped: self.stop() |