summaryrefslogtreecommitdiff
path: root/kafka/client.py
Commit message (Expand)AuthorAgeFilesLines
* Stop shadowing `ConnectionError`Stop-shadowing-native-python-ConnectionError-exceptionJeff Widman2018-05-101-6/+6
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-091-11/+1
* Update string representation of SimpleClientAndre Araujo2018-02-211-1/+1
* Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-151-9/+13
* Merge pull request #1213 from dpkp/1212-stop-using-mutable-types-for-default-...Taras Voinarovskyi2017-09-131-9/+9
|\
| * Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-valuesJeff Widman2017-09-121-9/+9
* | Fix typoJeff Widman2017-09-121-1/+1
|/
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-6/+2
* Add sphinx formatting to hyperlink methods (#898)Jeff Widman2017-03-031-7/+7
* Add send_list_offset_request for searching offset by timestamp (#1001)charsyam2017-03-021-0/+10
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-13/+12
* Use select to poll sockets for read to reduce CPU usage (#958)Jianbin Wei2017-02-031-0/+10
* Fix typosJeff Widman2016-11-141-1/+1
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* Delete KafkaConnection class (#769)Dana Powers2016-07-171-1/+2
* Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-161-3/+3
* Raise ConnectionError immediately on disconnect in SimpleClient._get_connDana Powers2016-04-081-1/+8
* Refactor SimpleClient connect logic to support multiple connecting statesDana Powers2016-04-071-11/+26
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-7/+7
* Kafka IPv6 Support.Tim Evens2016-03-301-8/+15
* catch all errors thrown by _get_leader_for_partition in SimpleClientZack Dever2016-03-171-1/+2
* Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topicsDana Powers2016-03-131-9/+13
* 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