openstack/deb-python-kafka
Code Issues Proposed changes

Async producer stop() fix

Browse Source
This commit is contained in:
Viktor Shlapakov
2015-02-26 13:33:40 +03:00
parent aedbbb39be
commit 5137163fa4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/producer/base.py
View File

@@ -210,5 +210,5 @@ class Producer(object):
self.queue.put((STOP_ASYNC_PRODUCER, None, None)) self.queue.put((STOP_ASYNC_PRODUCER, None, None))
self.thread.join(timeout) self.thread.join(timeout)
if self.thread.is_alive(): if self.thread.is_alive():
self.thread_stop_event.set() self.thread_stop_event.set()