diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-11 14:44:45 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-11 14:44:45 +0530 |
| commit | a4601d3a1bf6792e0d57e600f48e891ef2be1528 (patch) | |
| tree | df99626300f685359e0c5ec9569c978464278366 /kafka/queue.py | |
| parent | 77b8301e253774e09d13ff6b7c132fd51e6d9091 (diff) | |
| download | kafka-python-a4601d3a1bf6792e0d57e600f48e891ef2be1528.tar.gz | |
Spawn the commit thread only if necessary
If there are no messages being consumed, the timer keeps
creating new threads at the specified intervals. This may
not be necessary. We can control this behaviour such that
the timer thread is started only when a message is consumed
Diffstat (limited to 'kafka/queue.py')
0 files changed, 0 insertions, 0 deletions