| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Include zk-offset configuration in coordinator unit tests | Dana Powers | 2016-07-16 | 1 | -2/+6 | |
| | | ||||||
| * | Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706) | Dana Powers | 2016-07-16 | 3 | -23/+27 | |
| | | | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node | |||||
| * | Cleanup error logging (#760 / #759) | 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 | |||||
| * | Bump version for development | Dana Powers | 2016-07-15 | 1 | -1/+1 | |
| | | ||||||
| * | 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 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |