Async producer stop() fix

dpkp · Feb 26, 2015 · 5137163 · 5137163
1 parent aedbbb3
commit 5137163
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
@@ -210,5 +210,5 @@ def stop(self, timeout=1):
             self.queue.put((STOP_ASYNC_PRODUCER, None, None))
             self.thread.join(timeout)
 
-        if self.thread.is_alive():
-            self.thread_stop_event.set()
+            if self.thread.is_alive():
+                self.thread_stop_event.set()