summaryrefslogtreecommitdiff
path: root/kafka/queue.py
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-07-01 10:33:50 +0530
committerMahendra M <mahendra.m@gmail.com>2013-07-01 10:33:50 +0530
commit1d278f0f60cb0a7b76fbc6b80c8e112a0deb2e0c (patch)
tree85df9631f144ba94c979af52beed8e139f60489a /kafka/queue.py
parentc54a2edbaec1c4442cc63c8d3f0874b5882e90bb (diff)
downloadkafka-python-1d278f0f60cb0a7b76fbc6b80c8e112a0deb2e0c.tar.gz
Fix minor bug in offset management
In the current patch get_messages(count=1) would return zero messages the first time it is invoked after a consumer was initialized.
Diffstat (limited to 'kafka/queue.py')
0 files changed, 0 insertions, 0 deletions