Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | KakfaClient.check_version: Scan all brokers until a version is identified or ↵check_version | Dana Powers | 2016-06-18 | 1 | -12/+41 |
| | | | | timeout | ||||
* | Always process pending MetadataRequest in conn.check_version | Dana Powers | 2016-06-18 | 1 | -2/+2 |
| | |||||
* | Mute all connection logging during conn.check_version | Dana Powers | 2016-06-18 | 1 | -3/+3 |
| | |||||
* | 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 | 3 | -3/+61 |
| | | | | * 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 |
| | |||||
* | Rearrange connection tests to separate legacy KafkaConnection | Dana Powers | 2016-06-04 | 3 | -78/+74 |
| | |||||
* | Bump version for development | Dana Powers | 2016-06-01 | 1 | -1/+1 |
| | |||||
* | Patch Release 1.2.11.2.1 | Dana Powers | 2016-06-01 | 3 | -1/+21 |
| | |||||
* | Fix regression in MessageSet decoding wrt PartialMessages (#716) | Dana Powers | 2016-06-01 | 2 | -4/+107 |
| | |||||
* | Catch response decode errors and log details (#715) | Dana Powers | 2016-06-01 | 1 | -1/+14 |
| | |||||
* | Fix Legacy support url (#712) | Jonas Gröger | 2016-06-01 | 1 | -1/+1 |
| | |||||
* | Update docs/index.rst re 0.10 broker support | Dana Powers | 2016-05-24 | 1 | -4/+4 |
| | |||||
* | 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 |
| | |||||
* | Update changelog for 1.2.0 release | Dana Powers | 2016-05-24 | 2 | -1/+72 |
| | |||||
* | Update README re 0.10 brokers | Dana Powers | 2016-05-24 | 1 | -5/+5 |
| | |||||
* | Update compatibility for 0.10 kafka release | Dana Powers | 2016-05-24 | 4 | -6/+6 |
| | |||||
* | Add kafka 0.10.0.0 to test list | Dana Powers | 2016-05-24 | 2 | -1/+2 |
| | |||||
* | Disabling travis deploys -- relying on manual uploads for now | Dana Powers | 2016-05-24 | 1 | -10/+0 |
| | |||||
* | 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 | 2 | -13/+16 |
| | | | | | * 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 | 5 | -12/+62 |
| | | | | | | * 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 | 8 | -10/+127 |
| | |||||
* | Merge pull request #693 from dpkp/message_format_v1 | Dana Powers | 2016-05-22 | 12 | -961/+1188 |
|\ | | | | | Message format v1 (KIP-31 / KIP-32) | ||||
| * | Add some simple message protocol testsmessage_format_v1 | Dana Powers | 2016-05-22 | 1 | -0/+146 |
| | | |||||
| * | Rename legacy protocol tests | Dana Powers | 2016-05-22 | 1 | -0/+0 |
| | | |||||
| * | Improve consumer group test loop | Dana Powers | 2016-05-22 | 1 | -13/+13 |
| | | |||||
| * | 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 | 2 | -3/+30 |
| | | | | | [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 | ||||
* | | Merge pull request #678 from dpkp/check_version_0_10 | Dana Powers | 2016-05-03 | 4 | -3/+26 |
|\ \ | |/ |/| | Add protocol support for ApiVersionRequest | ||||
| * | 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 | 3 | -1/+23 |
| | |||||
* | Merge pull request #671 from dpkp/disconnects | Dana Powers | 2016-04-25 | 3 | -24/+87 |
|\ | | | | | Improve socket disconnect handling | ||||
| * | 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 |
| | | |||||
| * | Add disconnected socket tests for conn.recv() | Dana Powers | 2016-04-25 | 1 | -1/+46 |
| | | |||||
| * | Rename mocked socket as _socket in test_conn | Dana Powers | 2016-04-25 | 1 | -18/+16 |
|/ | |||||
* | handle unexpected reads in client_async | James Brown | 2016-04-25 | 1 | -0/+19 |
| | | | | Should fix #661. |