summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'master' into prod-windowsMahendra M2013-10-081-6/+18
|\
| * make changes to be more fault tolerant: clean up connections, brokers, failed...Jim Lim2013-10-041-6/+18
* | Ensure that async producer works in windows. Fixes #46Mahendra M2013-10-071-0/+11
|/
* Test fixes after flake8 runmrtheb2013-10-031-1/+2
* flake8 pass (pep8 and pyflakes)mrtheb2013-10-031-21/+20
* style: fix camelCase variable namesVetoshkin Nikita2013-10-031-3/+3
* style: use triple quotes for docstringsVetoshkin Nikita2013-10-031-2/+6
* style: fix whitespacesVetoshkin Nikita2013-10-031-1/+1
* allow a client id to be passed to the clientJim Lim2013-09-241-4/+5
* Merge branch 'issue-35'David Arthur2013-07-261-3/+11
|\
| * Re-init the sockets in the new processMahendra M2013-06-271-0/+4
| * Implement blocking get_messages for SimpleConsumerMahendra M2013-06-251-3/+7
* | Make the default case as 'ack on local write'Mahendra M2013-06-201-2/+11
|/
* Fix bugs and testingMahendra M2013-06-131-0/+5
* Finish making remaining files pep8 readyMahendra M2013-06-041-60/+109
* Minor bug fixesMahendra M2013-05-291-0/+6
* A few fixes for offset APIs in 0.8.1David Arthur2013-04-021-1/+1
* Update kafka-src to latest trunk, enable 0.8.1 featuresDavid Arthur2013-04-021-2/+0
* Update kafka-src to latest 0.8David Arthur2013-04-021-1/+1
* Bring acks and timeout down to the clientDavid Arthur2013-04-021-3/+3
* Refactoring a bit, cleanup for 0.8David Arthur2013-04-021-131/+136
* Big code re-orgDavid Arthur2013-04-021-641/+4
* Some work on a simple consumerDavid Arthur2013-04-021-4/+32
* Started on a simple producer and consumerDavid Arthur2013-04-021-6/+48
* Removing __main__ stuff from client.pyDavid Arthur2013-04-021-66/+0
* Integration tests passingDavid Arthur2013-04-021-498/+741
* Add a Queue-like producer/consumerDavid Arthur2012-11-191-0/+3
* Add Snappy support0.1-alphaDavid Arthur2012-11-161-1/+23
* Clean up imports in client, fixed #5David Arthur2012-10-301-3/+0
* Replace socket.send with socket.sendall, Fixes #6David Arthur2012-10-301-5/+5
* error handling fixBen Frederickson2012-10-251-1/+1
* Isn't it nice when tests actually find bugsDavid Arthur2012-10-021-4/+3
* Renaming kafka.py to client.pyDavid Arthur2012-10-021-0/+610