summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
...
* don't forget to call superclass __init__Vetoshkin Nikita2013-10-032-1/+3
* style: fix camelCase variable names againVetoshkin Nikita2013-10-031-2/+2
* style: remove extra brackets one more timeVetoshkin Nikita2013-10-031-5/+5
* style: remove extra bracketsVetoshkin Nikita2013-10-031-1/+1
* style: fix camelCase variable names once moreVetoshkin Nikita2013-10-031-3/+3
* style: fix camelCase variable namesVetoshkin Nikita2013-10-034-30/+29
* style: use triple quotes for docstringsVetoshkin Nikita2013-10-032-4/+12
* style: fix whitespacesVetoshkin Nikita2013-10-033-1/+7
* Cherry-pick mrtheb/kafka-python 2b016b69mrtheb2013-10-032-4/+8
* import bufferunderflow errorJim Lim2013-09-271-0/+2
* Fix #44 Add missing exception classv0.8.0David Arthur2013-09-245-17/+23
* allow a client id to be passed to the clientJim Lim2013-09-241-4/+5
* Auto-adjusting consumer fetch sizeDavid Arthur2013-09-093-21/+37
* Fixed #42, make fetch size configurableDavid Arthur2013-09-081-4/+7
* Merge branch 'issue-35'David Arthur2013-07-264-94/+445
|\
| * 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-273-1/+16
| * Fix a bug in seek.Mahendra M2013-06-271-0/+6
| * Merge branch 'master' into partitionMahendra M2013-06-252-26/+40
| |\
| * | Got MultiProcessConsumer workingMahendra M2013-06-251-10/+20
| * | Added some comments about message stateMahendra M2013-06-251-0/+7
| * | Implement blocking get_messages for SimpleConsumerMahendra M2013-06-252-16/+87
| * | Added the modules in __init__.pyMahendra M2013-06-251-2/+3
| * | Added more documentation and clean up duplicate codeMahendra M2013-06-251-86/+76
| * | Minor bug fixMahendra M2013-06-241-2/+3
| * | Add support for multi-process consumerMahendra M2013-06-241-48/+286
| * | Merge branch 'master' into partitionMahendra M2013-06-203-0/+93
| |\ \
| * | | Add support to consume messages from specific partitionsMahendra M2013-06-121-7/+11
* | | | Merge pull request #33 from mahendra/asyncproducerDavid Arthur2013-07-114-26/+202
|\ \ \ \
| * | | | Test cases for new producerMahendra M2013-06-271-1/+1
| * | | | Optimize sending of batch messagesMahendra M2013-06-261-6/+9
| * | | | Got batched mode to work properlyMahendra M2013-06-261-59/+48
| * | | | Update README with examplesMahendra M2013-06-261-1/+1
| * | | | Add support for batched message sendMahendra M2013-06-261-9/+100
| * | | | Merge branch 'master' into asyncproducerMahendra M2013-06-252-26/+40
| |\ \ \ \ | | | |_|/ | | |/| |
| * | | | Add exports in __init__Mahendra M2013-06-241-2/+4
| * | | | Make the default case as 'ack on local write'Mahendra M2013-06-203-6/+15
| * | | | Fix import errorsMahendra M2013-06-201-3/+5
| * | | | Add ack support for synchronous producerMahendra M2013-06-201-10/+39
| * | | | Merge branch 'master' into asyncproducerMahendra M2013-06-133-0/+95
| |\ \ \ \ | | | |_|/ | | |/| |
| * | | | Support for async producerMahendra M2013-06-131-8/+57
| | |_|/ | |/| |
* | | | Change auto_commit to False in SimpleConsumerDavid Arthur2013-06-251-1/+1
| |_|/ |/| |
* | | Merge branch 'master' into lazythreadMahendra M2013-06-253-0/+93
|\ \ \ | | |/ | |/|
| * | Fix bugs and testingMahendra M2013-06-133-5/+14
| * | Implement support for Keyed producerMahendra M2013-06-132-0/+84
| |/
* | Fix an issue with thread argumentMahendra M2013-06-121-1/+1
* | Optimize auto-commit threadMahendra M2013-06-122-33/+41