| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Avoid AttributeErrors in _unregister_cleanup (#747) | Dana Powers | 2016-07-05 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.2.3 | Dana Powers | 2016-07-02 | 1 | -1/+1 | |
| | | ||||||
| * | Randomize order of topics/partitions processed by fetcher to improve balance ↵ | Dana Powers | 2016-06-29 | 1 | -0/+4 | |
| | | | | | (#732) | |||||
| * | allow client.check_version timeout to be set in Producer and Consumer ↵ | eastlondoner | 2016-06-29 | 2 | -2/+10 | |
| | | | | | | constructors (#647) * allow client.check_version timeout to be set in Producer and Consumer constructors | |||||
| * | Wakeup socket optimizations (#740) | Dana Powers | 2016-06-26 | 2 | -2/+7 | |
| | | ||||||
| * | assert will be disabled by "python -O" (#736) | tyronecai | 2016-06-23 | 1 | -4/+4 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2016-06-21 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.2.21.2.2 | Dana Powers | 2016-06-21 | 1 | -1/+1 | |
| | | ||||||
| * | Clarify timeout unit (#734) | ms7s | 2016-06-21 | 1 | -1/+8 | |
| | | ||||||
| * | Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) | Dana Powers | 2016-06-20 | 2 | -30/+47 | |
| | | ||||||
| * | check_version should scan nodes until version found or timeout (#731) | Dana Powers | 2016-06-19 | 2 | -17/+46 | |
| | | | | | | * Mute all connection logging during conn.check_version * Always process pending MetadataRequest in conn.check_version * KakfaClient.check_version: Scan all brokers until a version is identified or timeout | |||||
| * | Update KafkaClient.least_loaded_node (#730) | Dana Powers | 2016-06-18 | 1 | -23/+17 | |
| | | | | | | | - Main node loop should check all known brokers, not just conn objects, which is consistent with the official java client. - This fixes a bug which could cause least_loaded_node to always return the same unavailable node | |||||
| * | Use weakref when registering a producer.close atexit to fix normal gc (#728) | Dana Powers | 2016-06-18 | 2 | -3/+47 | |
| | | | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread | |||||
| * | Close selector when closing the client connection to fix fd leak. (#729) | Michael Smith | 2016-06-17 | 1 | -0/+1 | |
| | | ||||||
| * | tweak spelling mistake (#719) | steve8918 | 2016-06-17 | 1 | -1/+1 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2016-06-01 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.2.11.2.1 | Dana Powers | 2016-06-01 | 1 | -1/+1 | |
| | | ||||||
| * | Fix regression in MessageSet decoding wrt PartialMessages (#716) | Dana Powers | 2016-06-01 | 1 | -3/+6 | |
| | | ||||||
| * | Catch response decode errors and log details (#715) | Dana Powers | 2016-06-01 | 1 | -1/+14 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2016-05-24 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.2.01.2.0 | Dana Powers | 2016-05-24 | 1 | -1/+1 | |
| | | ||||||
| * | KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699) | Dana Powers | 2016-05-22 | 1 | -7/+39 | |
| | | ||||||
| * | KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to ↵ | Dana Powers | 2016-05-22 | 3 | -11/+33 | |
| | | | | | guarantee ordering (#698) | |||||
| * | Dont use soon-to-be-reserved keyword await as function name ↵ | Dana Powers | 2016-05-22 | 2 | -3/+3 | |
| | | | | | (FutureProduceResult) (#697) | |||||
| * | Fix socket leaks in KafkaClient (#696) | Dana Powers | 2016-05-22 | 1 | -10/+10 | |
| | | | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close() | |||||
| * | Use standard LZ4 framing for v1 messages / kafka 0.10 (#695) | Dana Powers | 2016-05-22 | 4 | -12/+39 | |
| | | | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests | |||||
| * | Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) | Dana Powers | 2016-05-22 | 6 | -9/+66 | |
| | | ||||||
| * | KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵ | Dana Powers | 2016-05-22 | 7 | -50/+132 | |
| | | | | | messagesets | |||||
| * | Always pass encoded message bytes to MessageSet.encode() | Dana Powers | 2016-05-22 | 2 | -40/+22 | |
| | | ||||||
| * | raise ValueError on protocol encode/decode errors | Dana Powers | 2016-05-22 | 1 | -15/+32 | |
| | | ||||||
| * | Add CRL support to SSL support (#683) | Vincent Bernat | 2016-05-19 | 4 | -0/+29 | |
| | | | | | A user can provide a CRL whose peer certificate will be checked against. This only works with Python 3.4+ and Python 2.7.9+. | |||||
| * | Fixup BrokerConnection check_version strict error checking: 0.9 will fail ↵ | Dana Powers | 2016-05-17 | 1 | -0/+7 | |
| | | | | | with CorrelationIdError | |||||
| * | supplement socket.gaierror exception in BrokerConnection.connect() (#687) | Erik Beebe | 2016-05-17 | 1 | -3/+10 | |
| | | | | supplement socket.gaierror exception to include the host/port | |||||
| * | kafka/conn: use original hostname for SSL checks (#682) | Vincent Bernat | 2016-05-17 | 1 | -2/+4 | |
| | | | | | | | | | When the address family is not provided, `self.host` is resolved to one of the IP addresses and replaced by it. The SSL context is then built using `self.host` which is now an IP instead of the proper name. Most of the time, hostname cannot be checked this way. Therefore, save the original hostname in a dedicated property and use this property for the SSL context. | |||||
| * | * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ↵ | Paul Cavallaro | 2016-05-10 | 1 | -2/+12 | |
| | | | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages | |||||
| * | Merge pull request #679 from zackdever/kafka-PR-1265-bugfix | Zack Dever | 2016-05-03 | 1 | -1/+1 | |
| |\ | | | | | small bug fix in Sensor | |||||
| | * | small bug fix in Sensor | Zack Dever | 2016-05-03 | 1 | -1/+1 | |
| | | | | | | | pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99 | |||||
| * | | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10 | Dana Powers | 2016-05-02 | 4 | -3/+26 | |
| |/ | | | | check_version | |||||
| * | Patch release: 1.1.11.1.1 | Dana Powers | 2016-04-25 | 1 | -1/+1 | |
| | | ||||||
| * | Improve socket disconnect handlingdisconnects | Dana Powers | 2016-04-25 | 2 | -5/+23 | |
| | | ||||||
| * | Disable standard metadata refresh hook during bootstrap | Dana Powers | 2016-04-25 | 1 | -0/+2 | |
| | | ||||||
| * | handle unexpected reads in client_async | James Brown | 2016-04-25 | 1 | -0/+19 | |
| | | | | | Should fix #661. | |||||
| * | use the same logic for callbacks regardless of is_done status | Zack Dever | 2016-04-25 | 1 | -12/+15 | |
| | | ||||||
| * | Fix throttle_time_ms sensor | Zack Dever | 2016-04-25 | 1 | -1/+2 | |
| | | | | Fixes #665 | |||||
| * | Avoid some exceptions in Coordinator.__del__ (#668) | Dana Powers | 2016-04-25 | 2 | -2/+4 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2016-04-25 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.1.0 | Dana Powers | 2016-04-24 | 1 | -1/+1 | |
| | | ||||||
| * | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 1 | -24/+99 | |
| | | | | | Fixes #641 | |||||
| * | Wait for future.is_done in check_version (fix for windows) | Dana Powers | 2016-04-24 | 1 | -5/+5 | |
| | | ||||||
| * | Merge pull request #649 from jayalane/master | Dana Powers | 2016-04-24 | 1 | -2/+4 | |
| |\ | | | | | to squelch the __del issue | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |