summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Fixup SimpleClient.topic_partitions commentDana Powers2016-02-151-1/+1
* Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ...deprecation_warningsDana Powers2016-01-121-1/+7
* Docstring updatesDana Powers2016-01-071-21/+18
* Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-281-4/+4
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-37/+53
* new 0.9 error codes plus descriptions.Zack Dever2015-12-151-2/+2
* Only log topic names (and broker metadata) in KafkaClient load_metadata debug...Dana Powers2015-12-101-1/+1
* Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-101-2/+0
* Drop kafka_bytestringDana Powers2015-12-101-5/+2
* Refactor KafkaClient to use BrokerConnections and new Request/Response structsDana Powers2015-12-091-148/+131
* Revert broken send_produce_request try/except from PR 467 (resps=None)Dana Powers2015-12-051-5/+1
* Fix requestId handling in send_broker_aware_requestDana Powers2015-12-041-2/+2
* Merge pull request #420 from toddpalino/masterDana Powers2015-12-021-0/+128
|\
| * Support consumer metadata requeststpalino2015-07-011-0/+128
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-18/+30
|\ \
| * | Add tests. Bug fix. Rename socket_conn dict.Enrico Canzonieri2015-11-101-7/+7
| * | Unblocking broker aware requestEnrico Canzonieri2015-11-101-18/+30
* | | Prevents crashing communication thread of async producerBalthasar Schopman2015-10-221-1/+5
|/ /
* | Merge pull request #436 from mutability/async-catch-unavailable-errorDana Powers2015-10-071-6/+11
|\ \
| * | Init responses before we use it.Oliver Jowett2015-07-241-1/+1
| * | Errors -> Error typoOliver Jowett2015-07-201-1/+1
| * | Treat KafkaUnavailableError like other errors.Oliver Jowett2015-07-191-5/+10
| |/
* | Use debug logging level for metadata requestEnrico Canzonieri2015-07-211-2/+2
|/
* Lower logging level on replica not available and commitEnrico Canzonieri2015-06-191-1/+1
* Add KafkaClient.topics property to get list of known topicsDana Powers2015-06-111-0/+4
* Fix KafkaClient request / response orderingDana Powers2015-06-101-10/+20
* KafkaClient log new broker and topic metadata received as INFODana Powers2015-06-091-2/+2
* KafkaClient: log responses by requestId for debuggingDana Powers2015-06-091-1/+4
* KafkaClient: log requestId on ConnectionError instead of hexdump of request c...Dana Powers2015-06-091-6/+5
* Improve kafka client debug request/response loggingDana Powers2015-06-081-5/+5
* Prefer single quotes for stringsDana Powers2015-06-081-14/+12
* 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
View Lorry Controller Status