summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-011-2/+2
* Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-011-15/+28
* Raise UnknownTopicOrPartitionError immediately in ensure_topic_exists -- serv...Dana Powers2014-09-011-0/+4
* load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-011-12/+40
* Refactor internal metadata dicts in KafkaClientDana Powers2014-09-011-20/+56
* No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-011-3/+3
* Rearrange KafkaClient method order to group client metadata methods togetherDana Powers2014-09-011-18/+18
* Improve metadata protocol handlingDana Powers2014-09-011-9/+21
* Add pylint to tox.ini; test both kafka and test; default to error-checking on...Dana Powers2014-08-251-1/+1
* Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a testDana Powers2014-08-141-3/+3
* Handle New Topic CreationMark Roberts2014-05-221-9/+19
* 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
|/
View Lorry Controller Status