| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jythonbenchmarks | Dana Powers | 2016-07-16 | 2 | -0/+337 |
| | | |||||
| * | Move load_example.py to benchmarks/ | Dana Powers | 2016-07-16 | 1 | -0/+0 |
| | | |||||
| * | Update Sensor time_ms docs; only calculate if needed | Dana Powers | 2016-07-16 | 1 | -3/+3 |
| | | |||||
| * | First stab at public metrics() interface for KafkaConsumer / KafkaProducer | Dana Powers | 2016-07-16 | 2 | -2/+31 |
| | | |||||
| * | Add comment re fetcher stats on compressed topics | Dana Powers | 2016-07-16 | 1 | -0/+2 |
| | | |||||
| * | Fixup metrics_sample_window_ms docstring in consumer | Dana Powers | 2016-07-16 | 1 | -2/+2 |
| | | |||||
| * | KAFKA-3785: Fetcher spending unnecessary time during metrics recording | Dana Powers | 2016-07-16 | 1 | -2/+4 |
| | | |||||
| * | Add initial producer-sender metrics | Dana Powers | 2016-07-16 | 5 | -18/+261 |
| | | |||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 9 | -140/+146 |
| | | |||||
| * | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |