summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
Commit message (Expand)AuthorAgeFilesLines
* Attempt to fix travis build. Decrease complexity of service.py in favor of in...Mark Roberts2014-05-061-2/+2
* Make commit() check for errors instead of simply assert no errorMark Roberts2014-04-301-1/+1
* Make BrokerRequestError a base class, make subclasses for each broker errorMark Roberts2014-04-301-9/+7
* Various fixesMark Roberts2014-04-251-0/+3
* Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-241-1/+1
* Split out kafka version environments, default tox no longer runs any integrat...Mark Roberts2014-04-231-11/+11
* Split up and speed up producer based integration testsMark Roberts2014-04-171-1/+1
* Commit in seek if autocommitMark Roberts2014-03-271-1/+4
* Make seek(); commit(); work without commit discarding the seek changeMark Roberts2014-03-251-0/+1
* Resolve conflicts for #106Omar Ghishan2014-01-281-39/+70
|\
| * Add doc string for SimpleConsumer._get_message()Omar Ghishan2014-01-201-0/+6
| * Make get_messages() update and commit offsets just before returningOmar Ghishan2014-01-151-16/+35
| * Only use timeout if it's not NoneOmar Ghishan2014-01-151-4/+5
| * Store fetched offsets separately.Omar Ghishan2014-01-151-10/+14
| * Fix offset increments:Omar Ghishan2014-01-151-16/+17
* | Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra...mrtheb2014-01-141-0/+8
|\ \ | |/ |/|
| * Add proper string representations for each classMahendra M2013-10-081-0/+8
* | Exception hierarchy, invalidate more md on errorsThomas Dimson2014-01-131-1/+1
* | Merge pull request #88 from rdiomar/rdiomar_changesOmar2014-01-131-129/+140
|\ \
| * | Remove unnecessary bracketsOmar Ghishan2014-01-061-2/+2
| * | Add a limit to fetch buffer size, and actually retry requests when fetch size...Omar Ghishan2014-01-061-37/+58
| * | Fix seek offset deltasOmar Ghishan2014-01-061-6/+0
| * | Add comments and maintain 80 character line limitOmar Ghishan2014-01-061-7/+23
| * | Add iter_timeout option to SimpleConsumer. If not None, it causes the iterato...Omar Ghishan2014-01-061-6/+22
| * | Add buffer_size param description to docstring Omar Ghishan2014-01-061-1/+2
| * | Remove SimpleConsumer queue size limit since it can cause the iteratorOmar Ghishan2014-01-061-1/+1
| * | SimpleConsumer flow changes:Omar Ghishan2014-01-061-112/+70
| * | Reset consumer fields to original values rather than defaults in FetchContextOmar Ghishan2014-01-061-3/+5
| * | Allow None timeout in FetchContext even if block is FalseOmar Ghishan2014-01-061-4/+4
| * | * Guarantee reading the expected number of bytes from the socket every timeOmar Ghishan2014-01-061-2/+5
* | | Merge pull request #66 from jcrobak/fix-import-collisionDavid Arthur2014-01-081-0/+2
|\ \ \ | |/ / |/| |
| * | Enable absolute imports for modules using Queue.Joe Crobak2013-10-211-0/+2
* | | allow for timeout to be None in SimpleConsumer.get_messagesZack Dever2013-12-121-1/+2
|/ /
* | Ensure that multiprocess consumer works in windowsMahendra M2013-10-081-53/+63
|/
* flake8 pass (pep8 and pyflakes)mrtheb2013-10-031-23/+30
* remove unused exception instance variablesVetoshkin Nikita2013-10-031-1/+1
* Cherry-pick mrtheb/kafka-python 2b016b69mrtheb2013-10-031-1/+4
* Fix #44 Add missing exception classv0.8.0David Arthur2013-09-241-4/+3
* Auto-adjusting consumer fetch sizeDavid Arthur2013-09-091-15/+25
* Fixed #42, make fetch size configurableDavid Arthur2013-09-081-4/+7
* Fix minor bug in offset managementMahendra M2013-07-011-1/+4
* Add more cleanup in consumer.stop()Mahendra M2013-06-281-5/+7
* Fix cases of single partitionMahendra M2013-06-281-2/+3
* Add TODO commentsMahendra M2013-06-271-0/+2
* Re-init the sockets in the new processMahendra M2013-06-271-1/+3
* Fix a bug in seek.Mahendra M2013-06-271-0/+6
* Merge branch 'master' into partitionMahendra M2013-06-251-17/+9
|\
| * Optimize auto-commit threadMahendra M2013-06-121-21/+10
| * Spawn the commit thread only if necessaryMahendra M2013-06-111-2/+5
* | Got MultiProcessConsumer workingMahendra M2013-06-251-10/+20
View Lorry Controller Status