From 00d527f480299cc3c0298f3e4699c2f421d3fc64 Mon Sep 17 00:00:00 2001 From: Tom Most Date: Fri, 26 Feb 2016 17:37:41 -0800 Subject: [PATCH] Update base.py Our app uses `SimpleProducer` and logs lots of these warnings (from line 438): producer.stop() called, but producer is not async This destructor appears to be the cause. (Also, is it wise to do a thread join from a destructor?) --- kafka/producer/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()