summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* pylint 1.8.2 (#1369)Dana Powers2018-02-062-2/+2
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-0643-144/+144
* Add Request/Response structs for kafka broker 1.0.0Dana Powers2018-02-066-36/+167
* Avoid consuming duplicate compressed messages from mid-batch (#1367)Dana Powers2018-02-052-2/+51
* KAFKA-3949: Avoid race condition when subscription changes during rebalance (...Dana Powers2018-02-027-109/+128
* Add kafka 1.0.0 to travis integration testsDana Powers2018-02-011-0/+1
* Bump `lz4` in `requirements-dev.txt` (#1359)Jeff Widman2018-01-311-1/+1
* Use latest pytest 3.4.0, but drop pytest-sugar due to incompatibility (#1361)Dana Powers2018-01-312-3/+1
* Stop pinning lz4Jeff Widman2018-01-261-1/+1
* Use 0.11.0.2 kafka broker for integration testing (#1357)Dana Powers2018-01-257-4/+192
* Fix for Python 3 byte string handling in SASL auth (#1353)Christophe Lecointe2018-01-242-2/+4
* Remove assertion with side effect (#1348)Buğra Gedik2018-01-231-2/+2
* fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)C.YAO2018-01-231-1/+1
* Name heartbeat thread with group_id; use backoff when polling (#1345)Dana Powers2018-01-161-1/+1
* Minor test cleanups (#1343)Dana Powers2018-01-123-2/+5
* Avoid KeyError when filtering fetchable partitions (#1344)Dana Powers2018-01-121-2/+2
* Honor reconnect_backoff in conn.connect() (#1342)Dana Powers2018-01-112-1/+3
* Fix coordinator join_future race condition (#1338)Dana Powers2018-01-112-4/+21
* Read all available socket bytes (#1332)Dana Powers2018-01-104-22/+28
* Improve KafkaConsumer cleanup (#1339)Dana Powers2018-01-105-22/+62
* Fix typo in _try_authenticate_plain (#1333)everpcpc2017-12-281-1/+1
* Add security layer negotiation to the GSSAPI authentication. (#1283)Andre Araujo2017-12-261-22/+43
* Raise non-API exceptions (#1316)Jeff Widman2017-12-211-5/+1
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-2114-738/+977
* Pin pylint and lz4 to avoid breaking tests (#1330)Dana Powers2017-12-212-2/+4
* Minor Exception cleanupJeff Widman2017-12-127-10/+10
* Use non-deprecated exception handlingJeff Widman2017-12-121-1/+1
* Raise better struct pack/unpack errors (#1320)Jeff Widman2017-12-121-4/+8
* Followup cleanup to #1304Jeff Widman2017-12-081-2/+1
* Refactor dns lookup in BrokerConnection (#1312)Dana Powers2017-12-082-61/+74
* optimize util.crc32 (#1304)Ofek Lev2017-12-081-8/+15
* use python standard max value (#1303)lukeWx2017-12-074-4/+4
* changed for to use enumerate() (#1301)Benn Roth2017-12-061-2/+1
* Change fixture default host to localhost (#1305)Andre Araujo2017-12-051-15/+1
* Fix two bugs in printing bytes instanceAndre Araujo2017-11-271-1/+1
* Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239Dana Powers2017-11-162-30/+2
* Use correct casing for MBJeff Widman2017-11-152-2/+2
* Replace periods (java) with underscores (python)Jeff Widman2017-11-071-2/+2
* Add license to wheelJeff Widman2017-11-031-0/+3
* Use socket timeout of request_timeout_ms to prevent blocking forever on send ...Dana Powers2017-10-251-6/+7
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-242-5/+19
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...Taras Voinarovskyi2017-10-2518-31/+1696
* Fix more gssapi errors (#1280)Dana Powers2017-10-241-1/+4
* Add fixture support for upcoming 1.0.0 broker release (#1275)Dana Powers2017-10-234-2/+194
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-226-24/+195
* Fixup for PR 1264 -- required to propagate configuration to BrokerConnectionDana Powers2017-10-211-0/+3
* Fixup for PR 1258 / _try_authenticateDana Powers2017-10-211-1/+4
* Added controlled thread shutdown to example.py (#1268)Benn Roth2017-10-211-8/+32
* Merge pull request #1258 from dpkp/pending_completionsTaras Voinarovskyi2017-10-214-31/+65
|\
| * Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-154-31/+65