diff options
| -rw-r--r-- | kafka/producer/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index cf5abac..357bccd 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -210,5 +210,5 @@ class Producer(object): 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() |