| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | release lock on Exception in oauthconn_lock_release_gssapi_oauth | Dana Powers | 2019-06-29 | 1 | -0/+3 |
| | | |||||
| * | Fix conn lock release for gssapi/oauth | Dana Powers | 2019-06-29 | 1 | -0/+2 |
| | | |||||
| * | 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. | ||||
| * | Sanity test for consumer.topics() and consumer.partitions_for_topic() | Brian Sang | 2019-06-04 | 1 | -0/+9 |
| | | |||||
| * | 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 | 2 | -0/+15 |
| | | |||||
| * | 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 | 4 | -7/+29 |
| | | | | | | | | | | 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 | 2 | -7/+3 |
| | | |||||
| * | 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 | 3 | -1/+91 |
| | | |||||
| * | Do not call state_change_callback with lock (#1775) | Dana Powers | 2019-04-02 | 3 | -31/+40 |
| | | |||||
| * | 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 | 2 | -5/+13 |
| | | |||||
| * | 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 | 2 | -6/+6 |
| | | |||||
| * | Fixups to benchmark scripts for py3 / new KafkaFixture interfacebenchmark_fixups | Dana Powers | 2019-03-30 | 2 | -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 |
| | | |||||
| * | Rename ssl.keystore.location and ssl.truststore.location config files | Dana Powers | 2019-03-24 | 16 | -32/+36 |
| | | |||||
| * | 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 |
| | | |||||
| * | Support SASL OAuthBearer Authentication (#1750) | Phong Pham | 2019-03-22 | 7 | -6/+117 |
| | | |||||
| * | Fix flaky conn tests that use time.time (#1758) | Dana Powers | 2019-03-21 | 1 | -9/+12 |
| | | |||||
| * | Add py to requirements-dev | Dana Powers | 2019-03-21 | 1 | -0/+1 |
| | | |||||
| * | Maintain shadow cluster metadata for bootstrapping (#1753) | Dana Powers | 2019-03-21 | 2 | -35/+21 |
| | | |||||
| * | Allow configuration of SSL Ciphers (#1755) | Dana Powers | 2019-03-21 | 4 | -1/+28 |
| | | |||||
| * | Wrap SSL sockets after connecting (#1754) | Dana Powers | 2019-03-21 | 1 | -19/+11 |
| | | |||||
| * | Generate SSL certificates for local testing (#1756) | Dana Powers | 2019-03-21 | 1 | -0/+29 |
| | | | | This doesn't fully implement SSL fixtures, but as a first step it should help with automatically generating required certificates / keystores / etc. My hope is that this helps generate more community support for SSL testing! | ||||
| * | Fix race condition in protocol.send_bytes (#1752) | Filip Stefanak | 2019-03-21 | 1 | -1/+2 |
| | | |||||
| * | Forgot compatibility section in docs/changelog.rst | Dana Powers | 2019-03-14 | 1 | -0/+8 |
| | | |||||
| * | Bump version for development | Dana Powers | 2019-03-14 | 1 | -1/+1 |
| | | |||||
| * | Release 1.4.51.4.5 | Dana Powers | 2019-03-14 | 4 | -2/+102 |
| | | |||||
| * | Error if connections_max_idle_ms not larger than request_timeout_ms (#1688) | Jeff Widman | 2019-03-14 | 2 | -5/+13 |
| | | |||||
| * | Retry bootstrapping after backoff when necessary (#1736) | Dana Powers | 2019-03-14 | 3 | -129/+112 |
| | | | | | | | | The current client attempts to bootstrap once during initialization, but if it fails there is no second attempt and the client will be inoperable. This can happen, for example, if an entire cluster is down at the time a long-running client starts execution. This commit attempts to fix this by removing the synchronous bootstrapping from `KafkaClient` init, and instead merges bootstrap metadata with the cluster metadata. The Java client uses a similar approach. This allows us to continue falling back to bootstrap data when necessary throughout the life of a long-running consumer or producer. Fix #1670 | ||||
| * | Fix default protocol parser version | Dana Powers | 2019-03-13 | 1 | -0/+3 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |