Commit message (Expand) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | Fix #44 Add missing exception classv0.8.0 | David Arthur | 2013-09-24 | 1 | -4/+3 | |
* | Auto-adjusting consumer fetch size | David Arthur | 2013-09-09 | 1 | -15/+25 | |
* | Fixed #42, make fetch size configurable | David Arthur | 2013-09-08 | 1 | -4/+7 | |
* | Fix minor bug in offset management | Mahendra M | 2013-07-01 | 1 | -1/+4 | |
* | Add more cleanup in consumer.stop() | Mahendra M | 2013-06-28 | 1 | -5/+7 | |
* | Fix cases of single partition | Mahendra M | 2013-06-28 | 1 | -2/+3 | |
* | Add TODO comments | Mahendra M | 2013-06-27 | 1 | -0/+2 | |
* | Re-init the sockets in the new process | Mahendra M | 2013-06-27 | 1 | -1/+3 | |
* | Fix a bug in seek. | Mahendra M | 2013-06-27 | 1 | -0/+6 | |
* | Merge branch 'master' into partition | Mahendra M | 2013-06-25 | 1 | -17/+9 | |
|\ | ||||||
| * | Optimize auto-commit thread | Mahendra M | 2013-06-12 | 1 | -21/+10 | |
| * | Spawn the commit thread only if necessary | Mahendra M | 2013-06-11 | 1 | -2/+5 | |
* | | Got MultiProcessConsumer working | Mahendra M | 2013-06-25 | 1 | -10/+20 | |
* | | Added some comments about message state | Mahendra M | 2013-06-25 | 1 | -0/+7 | |
* | | Implement blocking get_messages for SimpleConsumer | Mahendra M | 2013-06-25 | 1 | -13/+80 | |
* | | Added more documentation and clean up duplicate code | Mahendra M | 2013-06-25 | 1 | -86/+76 | |
* | | Minor bug fix | Mahendra M | 2013-06-24 | 1 | -2/+3 | |
* | | Add support for multi-process consumer | Mahendra M | 2013-06-24 | 1 | -48/+286 | |
* | | Add support to consume messages from specific partitions | Mahendra M | 2013-06-12 | 1 | -7/+11 | |
|/ | ||||||
* | Refactor and update integration tests | Ivan Pouzyrevsky | 2013-06-07 | 1 | -0/+5 | |
* | Finish making remaining files pep8 ready | Mahendra M | 2013-06-04 | 1 | -34/+59 | |
* | Removing the bit about offsets | David Arthur | 2013-05-29 | 1 | -5/+0 | |
* | Minor bug fixes | Mahendra M | 2013-05-29 | 1 | -12/+29 | |
* | Merge branch 'issue-22' | David Arthur | 2013-05-28 | 1 | -0/+24 | |
|\ | ||||||
| * | Closes #22 | David Arthur | 2013-05-28 | 1 | -20/+0 | |
| * | Missed a doc string | Mahendra M | 2013-05-27 | 1 | -0/+2 | |
| * | New API for getting a specified set of messages | Mahendra M | 2013-05-27 | 1 | -0/+18 | |
| * | New API for checking pending message count | Mahendra M | 2013-05-27 | 1 | -0/+24 | |
* | | Auto commit timer is not periodic | Mahendra M | 2013-05-28 | 1 | -7/+18 | |
|/ | ||||||
* | Fixes #14 | David Arthur | 2013-04-11 | 1 | -1/+1 | |
* | Update kafka-src to latest trunk, enable 0.8.1 features | David Arthur | 2013-04-02 | 1 | -1/+0 | |
* | Refactoring a bit, cleanup for 0.8 | David Arthur | 2013-04-02 | 1 | -20/+51 | |
* | Big code re-org | David Arthur | 2013-04-02 | 1 | -0/+159 |