summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Attempt to fix travis build. Decrease complexity of service.py in favor of in...Mark Roberts2014-05-061-2/+0
* Make BrokerRequestError a base class, make subclasses for each broker errorMark Roberts2014-04-301-19/+17
* Refactor away _get_conn_for_broker. Fix bug in _get_connMark Roberts2014-04-091-13/+6
* Merge pull request #134 from wizzat/conn_refactorv0.9.0Dana Powers2014-03-211-3/+3
|\
| * Merge branch 'master' into conn_refactorMark Roberts2014-03-181-3/+3
| |\
| * \ Merge branch 'master' into conn_refactorMark Roberts2014-02-261-7/+18
| |\ \
| * | | Minor refactor in conn.py, update version in __init__.py, add ErrorStringMark Roberts2014-02-251-3/+3
* | | | Merge branch 'master' into developmrtheb2014-03-171-9/+20
|\ \ \ \ | | |_|/ | |/| |
| * | | If a broker refuses the connection, try the nextstephenarmstrong2014-03-131-3/+3
| | |/ | |/|
| * | Support list (or comma-separated) of hosts (replaces host and port arguments)mrtheb2014-02-091-6/+7
| * | Merge branch 'master' into multihostsmrtheb2014-01-311-91/+120
| |\ \ | | |/
| * | Allow KafkaClient to take in a list of brokers for bootstrappingMarc Labbe2013-11-141-14/+21
* | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ...mrtheb2014-02-151-4/+7
* | | check for broker None in send_broker_aware_request (added test for it)mrtheb2014-01-311-5/+14
* | | Handle cases for partition with leader=-1 (not defined)Marc Labbe2014-01-311-6/+12
* | | added mockmrtheb2014-01-181-3/+4
| |/ |/|
* | Merge pull request #107 from rdiomar/fix_default_timeoutsMarc Labbé2014-01-161-2/+6
|\ \
| * | Change default socket timeout to 120 seconds in both the client and connectionOmar Ghishan2014-01-161-2/+6
* | | Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra...mrtheb2014-01-141-0/+3
|\ \ \ | |/ / |/| |
| * | Add proper string representations for each classMahendra M2013-10-081-1/+4
| |/
* | Throw KafkaUnavailableError when no brokers availableThomas Dimson2014-01-131-2/+2
* | Exception hierarchy, invalidate more md on errorsThomas Dimson2014-01-131-80/+88
* | Change BufferUnderflowError to ConnectionError in conn._read_bytes()Omar Ghishan2014-01-081-3/+2
* | Fix client error handlingOmar Ghishan2014-01-061-5/+17
* | * Guarantee reading the expected number of bytes from the socket every timeOmar Ghishan2014-01-061-4/+3
* | Allow customizing socket timeouts.Omar Ghishan2014-01-061-3/+4
|/
* 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