From 5137163fa44b4a6a8a315c30f959e816f657e921 Mon Sep 17 00:00:00 2001 From: Viktor Shlapakov Date: Thu, 26 Feb 2015 13:33:40 +0300 Subject: [PATCH] Async producer stop() fix --- kafka/producer/base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/producer/base.py b/kafka/producer/base.py index cf5abac35..357bccd74 100644 --- 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()