summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this er...Dana Powers2015-01-141-1/+6
* Use six for py3 support in KafkaConsumerDana Powers2014-12-151-3/+3
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-63/+156
|\
| * 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
* | Fix test errors related to mocksMark Roberts2014-09-031-3/+4
* | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-3/+3
* | client_id in bytesBruno Renié2014-09-031-1/+1
* | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-1/+1
|/
* 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