| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Update docstring to match conn.py's (#1921) | David Bouchare | 2019-10-03 | 1 | -1/+2 |
| | | |||||
| * | Release 1.4.7 (#1916)1.4.7 | Dana Powers | 2019-09-30 | 1 | -1/+1 |
| | | |||||
| * | Follow up to PR 1782 -- fix tests (#1914) | Dana Powers | 2019-09-30 | 1 | -1/+2 |
| | | |||||
| * | Improve/refactor bootstrap_connected | Dana Powers | 2019-09-30 | 4 | -14/+22 |
| | | |||||
| * | Added a function to determine if bootstrap is successfully connected (#1876) | PandllCom | 2019-09-30 | 2 | -7/+20 |
| | | |||||
| * | Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due ↵ | Commander Dishwasher | 2019-09-30 | 2 | -8/+26 |
| | | | | | to topic deletion while rebalancing (#1782) | ||||
| * | Change coordinator lock acquisition order (#1821) | Dana Powers | 2019-09-29 | 2 | -43/+39 |
| | | |||||
| * | Send socket data via non-blocking IO with send buffer (#1912) | Dana Powers | 2019-09-29 | 3 | -12/+105 |
| | | |||||
| * | Do not use wakeup when sending fetch requests from consumer (#1911) | Dana Powers | 2019-09-29 | 1 | -1/+1 |
| | | |||||
| * | Rely on socket selector to detect completed connection attempts (#1909) | Dana Powers | 2019-09-28 | 3 | -9/+13 |
| | | |||||
| * | Wrap consumer.poll() for KafkaConsumer iteration (#1902) | Dana Powers | 2019-09-28 | 3 | -11/+74 |
| | | |||||
| * | Fix Admin Client api version checking; only test ACL integration on 0.11+ | Dana Powers | 2019-09-28 | 1 | -4/+10 |
| | | |||||
| * | Add ACL api to KafkaAdminClient (#1833) | Ulrik Johansson | 2019-09-28 | 4 | -9/+488 |
| | | |||||
| * | Improve connection lock handling; always use context manager (#1895) | Dana Powers | 2019-09-03 | 1 | -126/+151 |
| | | |||||
| * | Reduce internal client poll timeout for consumer iterator interface (#1824) | Dana Powers | 2019-08-16 | 1 | -3/+1 |
| | | | | More attempts to address heartbeat timing issues in consumers, especially with the iterator interface. Here we can reduce the `client.poll` timeout to at most the retry backoff (typically 100ms) so that the consumer iterator interface doesn't block for longer than the heartbeat timeout. | ||||
| * | Update conn.py | Cameron Boulton | 2019-08-16 | 1 | -0/+3 |
| | | |||||
| * | Break FindCoordinator into request/response methods | Jeff Widman | 2019-07-31 | 1 | -32/+48 |
| | | | | | | | | | | | | | | | | | | | This splits the `_find_coordinator_id()` method (which is blocking) into request generation / response parsing methods. The public API does not change. However, this allows power users who are willing to deal with risk of private methods changing under their feet to decouple generating the message futures from processing their responses. In other words, you can use these to fire a bunch of requests at once and delay processing the responses until all requests are fired. This is modeled on the work done in #1845. Additionally, I removed the code that tried to leverage the error checking from `cluster.add_group_coordinator()`. That code had changed in #1822, removing most of the error checking... so it no longer adds any value, but instead merely increases complexity and coupling. | ||||
| * | Fix minor typo (#1865) | Carson Ip | 2019-07-14 | 2 | -2/+2 |
| | | |||||
| * | Update link to upstream Kafka docs | Jeff Widman | 2019-07-11 | 1 | -1/+1 |
| | | | | the new consumer is now the standard consumer, so they dropped the `new_` from the anchor | ||||
| * | Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient` | Jeff Widman | 2019-06-28 | 1 | -0/+3 |
| | | | | | | | Previously the `sasl_kerberos_domain_name` was missing from the Admin client. It is already present in the Consumer/Producer, and in all three cases gets transparently passed down to the client. | ||||
| * | Update KafkaAdminClient Docs | Rob Cardy | 2019-06-21 | 1 | -1/+2 |
| | | | | Updated to include SASL_PLAINTEXT and SASL_SSL as options for security_protocol. | ||||
| * | Allow the coordinator to auto-commit for all api_version. | Jay Chan | 2019-06-20 | 1 | -1/+1 |
| | | |||||
| * | Break consumer operations into request / response methods (#1845) | Jeff Widman | 2019-06-19 | 1 | -94/+155 |
| | | | | | | | | | | | This breaks some of the consumer operations into request generation / response parsing methods. The public API does not change. However, this allows power users who are willing to deal with risk of private methods changing under their feet to decouple generating the message futures from processing their responses. In other words, you can use these to fire a bunch of request at once and delay processing the responses until all requests are fired. | ||||
| * | Use dedicated connection for group coordinator (#1822) | Dana Powers | 2019-06-19 | 2 | -25/+17 |
| | | | | This changes the coordinator_id to be a unique string, e.g., `coordinator-1`, so that it will get a dedicated connection. This won't eliminate lock contention because the client lock applies to all connections, but it should improve in-flight-request contention. | ||||
| * | Delay converting to seconds | Jeff Widman | 2019-05-30 | 1 | -2/+2 |
| | | | | | Delaying the conversion to seconds makes the code intent more clear. | ||||
| * | Reduce client poll timeout when no ifrs | Dana Powers | 2019-05-29 | 1 | -0/+3 |
| | | |||||
| * | Catch TimeoutError in BrokerConnection send/recv (#1820) | Dana Powers | 2019-05-29 | 1 | -6/+7 |
| | | |||||
| * | Remove unused/weird comment line (#1813) | Jeff Widman | 2019-05-28 | 1 | -1/+0 |
| | | |||||
| * | Update docs for api_version_auto_timeout_ms (#1812) | Jeff Widman | 2019-05-24 | 2 | -2/+2 |
| | | | | | | | | | | The docs for `api_version_auto_timeout_ms` mention setting `api_version='auto'` but that value has been deprecated for years in favor of `api_version=None`. Updating the docs for now, and will remove support for `'auto'` in next major version bump. | ||||
| * | Fix typo in _fetch_all_topic_metadata function (#1809) | Brian Sang | 2019-05-23 | 1 | -1/+1 |
| | | |||||
| * | Make partitions_for_topic a read-through cache (#1781) | Brian Sang | 2019-05-22 | 1 | -8/+25 |
| | | | | If the cluster metadata object has no info about the topic, then issue a blocking metadata call to fetch it. | ||||
| * | Remove unused imports (#1808) | Jeff Widman | 2019-05-22 | 1 | -2/+2 |
| | | |||||
| * | Use futures to parallelize calls to _send_request_to_node() (#1807) | Lou-Cipher | 2019-05-21 | 1 | -34/+75 |
| | | | | | | Use `futures` to parallelize calls to `_send_request_to_node()` This allows queries that need to go to multiple brokers to be run in parallel. | ||||
| * | Update link to kafka docs | Jeff Widman | 2019-05-17 | 1 | -1/+1 |
| | | | | Now that the old zookeeper consumer has been completely deprecated/removed, these are no longer the "new consumer configs" but rather simply the "consumer configs" | ||||
| * | A little python cleanup (#1805) | Jeff Widman | 2019-05-17 | 1 | -4/+2 |
| | | | | | | | 1. Remove unused variable: `partitions_for_topic` 2. No need to cast to list as `sorted()` already returns a list 3. Using `enumerate()` is cleaner than `range(len())` and handles assigning `member` | ||||
| * | Bump version for development of next release | Dana Powers | 2019-04-03 | 1 | -1/+1 |
| | | |||||
| * | Release 1.4.61.4.6 | Dana Powers | 2019-04-02 | 1 | -1/+1 |
| | | |||||
| * | Do not call state_change_callback with lock (#1775) | Dana Powers | 2019-04-02 | 2 | -21/+29 |
| | | |||||
| * | Additional BrokerConnection locks to synchronize protocol/IFR state (#1768) | Dana Powers | 2019-04-02 | 1 | -61/+85 |
| | | |||||
| * | Return connection state explicitly after close in connect() (#1778) | Dana Powers | 2019-04-02 | 1 | -1/+3 |
| | | |||||
| * | Reset reconnect backoff on SSL connection (#1777) | Dana Powers | 2019-04-02 | 1 | -0/+1 |
| | | |||||
| * | Fix possible AttribueError during conn._close_socket (#1776) | Dana Powers | 2019-04-01 | 1 | -1/+1 |
| | | |||||
| * | Dont treat popped conn.close() as failure in state change callback (#1773) | Dana Powers | 2019-04-01 | 1 | -3/+10 |
| | | |||||
| * | Avoid race condition on client._conns in send() (#1772) | Dana Powers | 2019-03-31 | 1 | -2/+3 |
| | | | | There was a very small possibility that between checking `self._can_send_request(node_id)` and grabbing the connection object via `self._conns[node_id]` that the connection could get closed / recycled / removed from _conns and cause a KeyError. This PR should prevent such a KeyError. In the case where the connection is disconnected by the time we call send(), we should expect conn.send() simply to fail the request. | ||||
| * | lock client.check_version (#1771) | Dana Powers | 2019-03-31 | 1 | -0/+5 |
| | | |||||
| * | Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769) | Dana Powers | 2019-03-30 | 1 | -4/+4 |
| | | |||||
| * | Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763) | Dana Powers | 2019-03-27 | 2 | -6/+9 |
| | | |||||
| * | Send pending requests before waiting for responses (#1762) | Dana Powers | 2019-03-27 | 1 | -2/+4 |
| | | |||||
| * | Dont do client wakeup when sending from sender thread (#1761) | Dana Powers | 2019-03-24 | 2 | -6/+10 |
| | | |||||
| * | Update sasl configuration docstrings | Dana Powers | 2019-03-23 | 5 | -24/+24 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |