summaryrefslogtreecommitdiff
path: root/kafka/queue.py
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-05-27 16:41:47 +0530
committerMahendra M <mahendra.m@gmail.com>2013-05-27 16:41:47 +0530
commit117c576c93ebc3e55d63707c26872de2b95dce73 (patch)
treed09b71334499923d5bc77e020e31a062098232e1 /kafka/queue.py
parent38215b66ebc70954c8448ce0397ac007ba35d697 (diff)
downloadkafka-python-117c576c93ebc3e55d63707c26872de2b95dce73.tar.gz
New API for getting a specified set of messages
This will be easier to use in some cases where we have to get only a specified set of messages. This API uses the __iter__ API internally, but maintains the state to give back only the required set of messages API is - get_messages(count=1)
Diffstat (limited to 'kafka/queue.py')
0 files changed, 0 insertions, 0 deletions