summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
Commit message (Expand)AuthorAgeFilesLines
* Separate consumers/producers/partitionersDana Powers2014-09-101-698/+0
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-6/+5
|\
| * Dont need to use callbacks for offset fetch requestsDana Powers2014-09-011-4/+3
| * Refactor internal metadata dicts in KafkaClientDana Powers2014-09-011-2/+2
* | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-4/+13
|\ \
| * | Fix the multiprocessing tests for python 3Mark Roberts2014-09-031-1/+1
| * | Cross-python iteritemsBruno Renié2014-09-031-1/+3
| * | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-2/+9
| |/
* | Minor import cleanupsDana Powers2014-09-041-6/+6
|/
* Merge pull request #136 from DataDog/fix-multifetch-buffer-sizeDana Powers2014-08-261-12/+14
|\
| * fix consumer retry logic (fixes #135)Carlo Cabanilla2014-02-281-12/+14
* | also reset `self.fetch_offsets` in `fetch_last_known_offsets`Zack Dever2014-08-251-0/+1
* | Move fetching last known offset logic to a stand alone function.Zack Dever2014-08-251-10/+16
* | 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
View Lorry Controller Status