| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Error if connections_max_idle_ms not larger than request_timeout_ms (#1688) | Jeff Widman | 2019-03-14 | 1 | -3/+7 |
| | | |||||
| * | Do network connections and writes in KafkaClient.poll() (#1729) | Dana Powers | 2019-03-08 | 1 | -12/+1 |
| | | | | | | | * Add BrokerConnection.send_pending_requests to support async network sends * Send network requests during KafkaClient.poll() rather than in KafkaClient.send() * Dont acquire lock during KafkaClient.send if node is connected / ready * Move all network connection IO into KafkaClient.poll() | ||||
| * | Remove unused `skip_double_compressed_messages` | Jeff Widman | 2019-01-13 | 1 | -8/+0 |
| | | | | | | | | | | | This `skip_double_compressed_messages` flag was added in https://github.com/dpkp/kafka-python/pull/755 in order to fix https://github.com/dpkp/kafka-python/issues/718. However, grep'ing through the code, it looks like it this is no longer used anywhere and doesn't do anything. So removing it. | ||||
| * | #1681 add copy() in metrics() to avoid thread safety issues (#1682) | Tosi Émeric | 2018-12-27 | 1 | -2/+2 |
| | | |||||
| * | Be explicit with tuples for %s formatting | Jeff Widman | 2018-11-18 | 1 | -1/+1 |
| | | | | | Fix #1633 | ||||
| * | add kerberos domain name config for gssapi sasl mechanism handshake (#1542) | the-sea | 2018-08-31 | 1 | -1/+4 |
| | | |||||
| * | Document connections_max_idle_ms | Jeff Widman | 2018-06-26 | 1 | -0/+5 |
| | | | | | | This was added in #1068 but never documented. Fix #1497 | ||||
| * | Fix KafkaConsumer docstring for request_timeout_ms default (#1459) | Dana Powers | 2018-03-23 | 1 | -1/+1 |
| | | |||||
| * | Do not validate api_version against known versions (#1434) | Dana Powers | 2018-03-10 | 1 | -2/+1 |
| | | |||||
| * | Avoid tight poll loop in consumer when brokers are down (#1415) | Dana Powers | 2018-03-08 | 1 | -1/+1 |
| | | |||||
| * | Validate max_records in KafkaConsumer.poll (#1398) | Dana Powers | 2018-02-27 | 1 | -0/+2 |
| | | |||||
| * | Correctly respect timeouts in consumer poll interface (#1384) | Braedon Vickers | 2018-02-21 | 1 | -1/+1 |
| | | |||||
| * | KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵ | Dana Powers | 2018-02-02 | 1 | -0/+10 |
| | | | | | (#1364) | ||||
| * | Read all available socket bytes (#1332) | Dana Powers | 2018-01-10 | 1 | -0/+2 |
| | | | | | * Recv all available network bytes before parsing * Add experimental support for configuring socket chunking parameters | ||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -46/+56 |
| | | |||||
| * | Use correct casing for MB | Jeff Widman | 2017-11-15 | 1 | -1/+1 |
| | | | | | | | These values refer to Megabytes, not Megabits. Fix #1295 | ||||
| * | Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer ↵ | Nathanael Smith | 2017-10-17 | 1 | -0/+3 |
| | | | | | (#1264) | ||||
| * | Fix docstring | Jeff Widman | 2017-10-16 | 1 | -3/+4 |
| | | |||||
| * | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254) | Dana Powers | 2017-10-11 | 1 | -10/+19 |
| | | |||||
| * | Expand metrics docs (#1243) | Jeff Widman | 2017-10-08 | 1 | -4/+11 |
| | | | | | | | * Expand metrics docstrings * Document metrics interface in readme * Use six.iteritems(d) rather than d.items() * Use Sphinx warning syntax | ||||
| * | remove beginning/end offsets request version limit | Liao Jiayi | 2017-09-04 | 1 | -8/+0 |
| | | |||||
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 1 | -1/+0 |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | ||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 1 | -2/+4 |
| | | |||||
| * | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -11/+76 |
| | | | | | review issues | ||||
| * | Changed retrieve_offsets to allow fetching multiple offsets at once | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+3 |
| | | |||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+41 |
| | | | | | and send in parallel. | ||||
| * | KIP-144: Exponential backoff for broker reconnections (#1124) | Dana Powers | 2017-06-19 | 1 | -0/+9 |
| | | |||||
| * | Describe consumer thread-safety | Linus Wallgren | 2017-06-16 | 1 | -0/+2 |
| | | |||||
| * | Follow-up to #1068: remove not-implemented comments | Dana Powers | 2017-04-10 | 1 | -1/+1 |
| | | |||||
| * | Additional docstrings for autocommit close option | Dana Powers | 2017-03-13 | 1 | -1/+7 |
| | | |||||
| * | Optionally skip auto-commit during consumer.close (#1031) | Dana Powers | 2017-03-13 | 1 | -2/+2 |
| | | |||||
| * | Return copy of consumer subscription set (#1029) | Dana Powers | 2017-03-13 | 1 | -1/+1 |
| | | |||||
| * | A few Sphinx documentation updates (#1019) | Jeff Widman | 2017-03-08 | 1 | -3/+3 |
| | | |||||
| * | Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc | Dana Powers | 2017-03-07 | 1 | -23/+35 |
| | | |||||
| * | Disable default consumer group (#1016) | Dana Powers | 2017-03-06 | 1 | -2/+2 |
| | | |||||
| * | Added `max_bytes` option and FetchRequest_v3 usage. (#962) | Taras Voinarovskyi | 2017-03-06 | 1 | -0/+9 |
| | | | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse | ||||
| * | Add sphinx formatting to hyperlink methods (#898) | Jeff Widman | 2017-03-03 | 1 | -22/+22 |
| | | |||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+5 |
| | | |||||
| * | Fail-fast on timeout constraint violations during KafkaConsumer creation (#986) | Harel Ben-Attia | 2017-02-28 | 1 | -0/+13 |
| | | |||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 1 | -3/+3 |
| | | |||||
| * | Default max_poll_records to Java default of 500 (#947) | Jeff Widman | 2017-01-18 | 1 | -2/+2 |
| | | |||||
| * | Spelling and grammar changes (#923) | melissacrawford396 | 2017-01-11 | 1 | -87/+85 |
| | | |||||
| * | Add metadata update to pattern subscribing (#915) | Dmitry Lazurkin | 2016-12-27 | 1 | -0/+1 |
| | | |||||
| * | Add docstring for max_records (#897) | Jeff Widman | 2016-12-19 | 1 | -0/+3 |
| | | |||||
| * | Added doc for `max_poll_records` option (#881) | Taras Voinarovskyi | 2016-11-20 | 1 | -1/+2 |
| | | |||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 1 | -3/+3 |
| | | |||||
| * | Revert consumer iterators from max_poll_records (#856) | Dana Powers | 2016-10-24 | 1 | -7/+88 |
| | | |||||
| * | KAFKA-3007: KafkaConsumer max_poll_records (#831) | Dana Powers | 2016-09-28 | 1 | -105/+29 |
| | | |||||
| * | Treat metric_group_prefix as config in KafkaConsumer | Dana Powers | 2016-08-04 | 1 | -3/+3 |
| | | |||||
| * | Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient | Dana Powers | 2016-08-04 | 1 | -1/+1 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |