diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-26 13:33:40 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-26 13:33:40 +0300 |
| commit | 5137163fa44b4a6a8a315c30f959e816f657e921 (patch) | |
| tree | 836f1c5ee358941ad5d76b2f5eceb6b80de88274 | |
| parent | aedbbb39be4d207ba9eaf99811980276d44f39a5 (diff) | |
| download | kafka-python-5137163fa44b4a6a8a315c30f959e816f657e921.tar.gz | |
Async producer stop() fix
| -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() |