summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Clarify timeout unit (#734)ms7s2016-06-211-1/+8
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-202-30/+47
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-192-17/+46
* Update KafkaClient.least_loaded_node (#730)Dana Powers2016-06-181-23/+17
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-182-3/+47
* Close selector when closing the client connection to fix fd leak. (#729)Michael Smith2016-06-171-0/+1
* tweak spelling mistake (#719)steve89182016-06-171-1/+1
* Bump version for developmentDana Powers2016-06-011-1/+1
* Patch Release 1.2.11.2.1Dana Powers2016-06-011-1/+1
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-3/+6
* Catch response decode errors and log details (#715)Dana Powers2016-06-011-1/+14
* Bump version for developmentDana Powers2016-05-241-1/+1
* Release 1.2.01.2.0Dana Powers2016-05-241-1/+1
* KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699)Dana Powers2016-05-221-7/+39
* KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarant...Dana Powers2016-05-223-11/+33
* Dont use soon-to-be-reserved keyword await as function name (FutureProduceRes...Dana Powers2016-05-222-3/+3
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-10/+10
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-224-12/+39
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-226-9/+66
* 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-101-2/+12
* 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
* | 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-251-1/+1
* Improve socket disconnect handlingdisconnectsDana Powers2016-04-252-5/+23
* Disable standard metadata refresh hook during bootstrapDana Powers2016-04-251-0/+2
* handle unexpected reads in client_asyncJames Brown2016-04-251-0/+19
* use the same logic for callbacks regardless of is_done statusZack Dever2016-04-251-12/+15
* Fix throttle_time_ms sensorZack Dever2016-04-251-1/+2
* Avoid some exceptions in Coordinator.__del__ (#668)Dana Powers2016-04-252-2/+4
* Bump version for developmentDana Powers2016-04-251-1/+1
* Release 1.1.0Dana Powers2016-04-241-1/+1
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-241-24/+99
* 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
* | instrument metrics for fetch requestsZack Dever2016-04-132-65/+93
* | 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-132-47/+53
* | Basic dictionary reporter in place of the java JMX reporter.Zack Dever2016-04-132-1/+84
* | Kafka metrics java port. No reporters or instrumentation.Zack Dever2016-04-1324-0/+1250
|/