summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Dont warn on socket disconnections caused by KafkaClient.close()fix_leaksDana Powers2016-05-221-1/+3
* Cleanup unneeded bootstrap connection to avoid leak in KafkaClientDana Powers2016-05-222-4/+9
* Cleanup wakeup socketpair on close to avoid leak in KafkaClientDana Powers2016-05-221-8/+4
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-228-10/+127
* Merge pull request #693 from dpkp/message_format_v1Dana Powers2016-05-2212-961/+1188
|\
| * Add some simple message protocol testsmessage_format_v1Dana Powers2016-05-221-0/+146
| * Rename legacy protocol testsDana Powers2016-05-221-0/+0
| * Improve consumer group test loopDana Powers2016-05-221-13/+13
| * KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...Dana Powers2016-05-227-50/+132
| * Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-222-40/+22
| * raise ValueError on protocol encode/decode errorsDana Powers2016-05-221-15/+32
|/
* Add CRL support to SSL support (#683)Vincent Bernat2016-05-194-0/+29
* Fixup BrokerConnection check_version strict error checking: 0.9 will fail wit...Dana Powers2016-05-171-0/+7
* supplement socket.gaierror exception in BrokerConnection.connect() (#687)Erik Beebe2016-05-171-3/+10
* kafka/conn: use original hostname for SSL checks (#682)Vincent Bernat2016-05-171-2/+4
* * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ...Paul Cavallaro2016-05-102-3/+30
* Merge pull request #679 from zackdever/kafka-PR-1265-bugfixZack Dever2016-05-031-1/+1
|\
| * small bug fix in SensorZack Dever2016-05-031-1/+1
* | Merge pull request #678 from dpkp/check_version_0_10Dana Powers2016-05-034-3/+26
|\ \ | |/ |/|
| * Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_ve...check_version_0_10Dana Powers2016-05-024-3/+26
|/
* Patch release: 1.1.11.1.1Dana Powers2016-04-253-1/+23
* Merge pull request #671 from dpkp/disconnectsDana Powers2016-04-253-24/+87
|\
| * Improve socket disconnect handlingdisconnectsDana Powers2016-04-252-5/+23
| * Disable standard metadata refresh hook during bootstrapDana Powers2016-04-251-0/+2
| * Add disconnected socket tests for conn.recv()Dana Powers2016-04-251-1/+46
| * Rename mocked socket as _socket in test_connDana Powers2016-04-251-18/+16
|/
* handle unexpected reads in client_asyncJames Brown2016-04-251-0/+19
* Merge pull request #670 from zackdever/predictable-futureDana Powers2016-04-253-13/+19
|\
| * enable errors on callbacks in testing. fix broken test.Zack Dever2016-04-252-1/+4
| * use the same logic for callbacks regardless of is_done statusZack Dever2016-04-251-12/+15
* | Allow setting host interface in KafkaFixture.instanceDana Powers2016-04-251-2/+4
|/
* Fix throttle_time_ms sensorZack Dever2016-04-251-1/+2
* Build universal wheels - kafka-python is compatible with both py2 and py3Dana Powers2016-04-251-0/+2
* Avoid some exceptions in Coordinator.__del__ (#668)Dana Powers2016-04-252-2/+4
* Bump version for developmentDana Powers2016-04-251-1/+1
* Fix hyperlinks in README to fix pypi rendering1.1.0Dana Powers2016-04-241-5/+5
* Release 1.1.0Dana Powers2016-04-241-1/+1
* Update changelogs for 1.1.0 releaseDana Powers2016-04-242-0/+84
* Merge branch 'EasyPost-better_ipv6'Dana Powers2016-04-245-43/+137
|\
| * More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-245-43/+137
|/
* Wait for future.is_done in check_version (fix for windows)Dana Powers2016-04-241-5/+5
* Merge pull request #649 from jayalane/masterDana Powers2016-04-241-2/+4
|\
| * as per code reviewChris Lane2016-04-141-2/+2
| * to squelch the __del issueChris Lane2016-04-131-2/+4
* | Merge pull request #637 from zackdever/metricsZack Dever2016-04-1432-121/+1994
|\ \ | |/ |/|
| * instrument metrics for fetch requestsZack Dever2016-04-133-66/+95
| * trying to use locks a little less. still not ideal.Zack Dever2016-04-134-19/+18
| * Changing some commented out metrics to avoid future gotchas.Zack Dever2016-04-132-4/+4
| * Beginnings of metrics instrumentation in kafka consumer.Zack Dever2016-04-133-53/+66
| * Basic dictionary reporter in place of the java JMX reporter.Zack Dever2016-04-133-4/+120