Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Cleanup error loggingerrors | Dana Powers | 2016-07-15 | 2 | -2/+12 |
| | | | | | | | - add error type to all KafkaErrors - add args to BrokerResponseError - drop description from BrokerResponseError - fix bug logging errbacks as callbacks | ||||
* | Patch Release 1.2.51.2.5 | Dana Powers | 2016-07-15 | 3 | -1/+19 |
| | |||||
* | Merge pull request #755 from dpkp/unrecurse_unpack_message_set | Dana Powers | 2016-07-15 | 2 | -17/+64 |
|\ | | | | | Drop recursion in Fetcher _unpack_message_set | ||||
| * | Add skip_double_compressed_messages option to KafkaConsumerunrecurse_unpack_message_set | Dana Powers | 2016-07-14 | 2 | -0/+20 |
| | | |||||
| * | Log warning if message set appears double-compressed in KafkaConsumer | Dana Powers | 2016-07-14 | 1 | -0/+8 |
| | | |||||
| * | Drop recursion in _unpack_message_set | Dana Powers | 2016-07-14 | 1 | -17/+36 |
|/ | |||||
* | Merge pull request #757 from dpkp/double_compression | Dana Powers | 2016-07-14 | 2 | -16/+93 |
|\ | | | | | Fix bug causing KafkaProducer to double-compress message batches | ||||
| * | Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compression | Dana Powers | 2016-07-14 | 1 | -16/+23 |
| | | |||||
| * | Test MessageSetBuffer close -- cover double close compression bug | Dana Powers | 2016-07-14 | 1 | -0/+70 |
|/ | |||||
* | Bump version for development | Dana Powers | 2016-07-10 | 1 | -1/+1 |
| | |||||
* | Patch Release 1.2.41.2.4 | Dana Powers | 2016-07-08 | 3 | -1/+21 |
| | |||||
* | Update consumer_timeout_ms docstring per #749 | Dana Powers | 2016-07-08 | 1 | -3/+3 |
| | |||||
* | Merge pull request #752 from dpkp/compacted_offsets | Dana Powers | 2016-07-08 | 2 | -2/+18 |
|\ | | | | | Fix consumer iteration on compacted topics | ||||
| * | Use explicit subscription state flag to handle seek() during message iterationcompacted_offsets | Dana Powers | 2016-07-08 | 2 | -1/+17 |
| | | |||||
| * | Fix consumer iteration on compacted topics | Dana Powers | 2016-07-08 | 1 | -1/+1 |
|/ | |||||
* | Add ssl_password to default_config dicts. Send ssl_password when loading ↵ | Ashley McKemie | 2016-07-08 | 3 | -1/+5 |
| | | | | cert chains (#750) | ||||
* | Push out one more patch for 1.2.3 release1.2.3 | Dana Powers | 2016-07-05 | 2 | -0/+2 |
| | |||||
* | Avoid AttributeErrors in _unregister_cleanup (#747) | Dana Powers | 2016-07-05 | 1 | -1/+1 |
| | |||||
* | Patch Release 1.2.3 | Dana Powers | 2016-07-02 | 3 | -1/+21 |
| | |||||
* | 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 | 3 | -2/+11 |
| | | | | | 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 | 3 | -1/+29 |
| | |||||
* | 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 | 3 | -32/+147 |
| | |||||
* | 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 | 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() |