summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
...
* Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-081-2/+5
* Cleanup imports in kafka/client and kafka/consumerDana Powers2015-06-081-1/+1
* KafkaClient should try/except ConnnectionError when calling _get_connDana Powers2015-06-061-2/+2
* Raise an error if we attempt to group duplicate topic-partition payloadsDana Powers2015-06-061-0/+2
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+2
* Merge pull request #367 from dpkp/clean_metadata_refreshDana Powers2015-04-121-13/+14
|\
| * Update debug log messages in client.load_metadata_for_topicsDana Powers2015-04-121-2/+2
| * clean local metadata before requesting refresh in load_metadata_for_topics()Dana Powers2015-04-121-2/+7
| * Simplify client.reset_topic_metadataDana Powers2015-04-121-9/+5
* | Improve send_produce_request docstringDana Powers2015-04-061-6/+17
* | Add debug logging for all broker-aware requests/responsesDana Powers2015-04-061-0/+3
* | Refactor KafkaClient._send_broker_aware_request to return a list of responsesDana Powers2015-04-061-73/+57
|/
* Make external API consistently support python3 strings for topic.Space2015-04-031-0/+3
* Rollover KafkaClient correlation ids at 2**31 to keep within int32 protocol e...Dana Powers2015-03-291-7/+7
* KafkaClient.get_partition_ids_for_topic now returns empty list for unknown to...Dana Powers2015-03-021-1/+1
* Add comment about no server response case in _send_broker_aware_requestDana Powers2015-03-021-0/+5
* Avoid topic_partitions KeyError in KafkaClientDana Powers2015-03-021-1/+1
* Accept KafkaClient client_id as string or bytes; encode string client_id as u...Dana Powers2015-03-011-1/+2
* Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic()Dana Powers2015-02-091-1/+1
* Merge pull request #282 from wedaly/sphinx-api-docsDana Powers2015-01-231-24/+24
|\
| * Add Sphinx API docsWill Daly2015-01-151-24/+24
* | 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
| |\ \ | | |/
View Lorry Controller Status