| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix initialization order in KafkaClient (#2119) | Pedro Calleja | 2020-09-16 | 1 | -3/+6 |
| | | | | Fix initialization order in KafkaClient | ||||
| * | remove unused imports | James Lamb | 2020-07-10 | 1 | -1/+0 |
| | | |||||
| * | Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918) | Swen Wenzel | 2019-12-29 | 1 | -9/+6 |
| | | |||||
| * | Improve docs for reconnect_backoff_max_ms (#1976) | Dana Powers | 2019-12-28 | 1 | -5/+6 |
| | | |||||
| * | Fix typos | Carson Ip | 2019-11-08 | 1 | -1/+1 |
| | | |||||
| * | Update docstring to match conn.py's (#1921) | David Bouchare | 2019-10-03 | 1 | -1/+2 |
| | | |||||
| * | Improve/refactor bootstrap_connected | Dana Powers | 2019-09-30 | 1 | -0/+10 |
| | | |||||
| * | Change coordinator lock acquisition order (#1821) | Dana Powers | 2019-09-29 | 1 | -1/+3 |
| | | |||||
| * | Send socket data via non-blocking IO with send buffer (#1912) | Dana Powers | 2019-09-29 | 1 | -2/+27 |
| | | |||||
| * | Rely on socket selector to detect completed connection attempts (#1909) | Dana Powers | 2019-09-28 | 1 | -3/+7 |
| | | |||||
| * | 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 |
| | | |||||
| * | Do not call state_change_callback with lock (#1775) | Dana Powers | 2019-04-02 | 1 | -8/+8 |
| | | |||||
| * | 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 |
| | | |||||
| * | 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 | 1 | -4/+7 |
| | | |||||
| * | Update sasl configuration docstrings | Dana Powers | 2019-03-23 | 1 | -5/+5 |
| | | |||||
| * | Support SASL OAuthBearer Authentication (#1750) | Phong Pham | 2019-03-22 | 1 | -1/+4 |
| | | |||||
| * | Maintain shadow cluster metadata for bootstrapping (#1753) | Dana Powers | 2019-03-21 | 1 | -25/+10 |
| | | |||||
| * | Allow configuration of SSL Ciphers (#1755) | Dana Powers | 2019-03-21 | 1 | -0/+6 |
| | | |||||
| * | Retry bootstrapping after backoff when necessary (#1736) | Dana Powers | 2019-03-14 | 1 | -83/+66 |
| | | | | | | | | 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 | ||||
| * | Minor updates to client_async.py | Dana Powers | 2019-03-13 | 1 | -4/+4 |
| | | |||||
| * | Recheck connecting nodes sooner when refreshing metadata (#1737) | Dana Powers | 2019-03-13 | 1 | -3/+1 |
| | | |||||
| * | Do network connections and writes in KafkaClient.poll() (#1729) | Dana Powers | 2019-03-08 | 1 | -16/+43 |
| | | | | | | | * 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() | ||||
| * | Do not require client lock for read-only operations (#1730) | Dana Powers | 2019-03-06 | 1 | -50/+50 |
| | | | | In an effort to reduce the surface area of lock coordination, and thereby hopefully reduce lock contention, I think we can remove locking from the read-only KafkaClient methods: connected, is_disconnected, in_flight_request_count, and least_loaded_node . Given that the read data could change after the lock is released but before the caller uses it, the value of acquiring a lock here does not seem high to me. | ||||
| * | Break KafkaClient poll if closed | Dana Powers | 2018-11-20 | 1 | -0/+2 |
| | | |||||
| * | Be explicit with tuples for %s formatting | Jeff Widman | 2018-11-18 | 1 | -1/+1 |
| | | | | | Fix #1633 | ||||
| * | Use TypeError for invalid type | Jeff Widman | 2018-11-17 | 1 | -1/+1 |
| | | |||||
| * | set socket timeout for the wake_w (#1577) | flaneur | 2018-11-10 | 1 | -0/+5 |
| | | |||||
| * | (Attempt to) Fix deadlock between consumer and heartbeat (#1628) | Dana Powers | 2018-11-10 | 1 | -3/+1 |
| | | |||||
| * | Add KafkaAdmin class | Richard Lee | 2018-10-24 | 1 | -0/+16 |
| | | | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper. | ||||
| * | add kerberos domain name config for gssapi sasl mechanism handshake (#1542) | the-sea | 2018-08-31 | 1 | -0/+3 |
| | | |||||
| * | add support for smaller topic metadata fetch during bootstrap (#1541) | Ning Xie | 2018-08-31 | 1 | -3/+10 |
| | | |||||
| * | Document connections_max_idle_ms | Jeff Widman | 2018-06-26 | 1 | -0/+5 |
| | | | | | | This was added in #1068 but never documented. Fix #1497 | ||||
| * | Stop shadowing `ConnectionError` | Jeff Widman | 2018-05-23 | 1 | -1/+1 |
| | | | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues. | ||||
| * | Minor doc capitalization cleanup | Jeff Widman | 2018-04-24 | 1 | -15/+15 |
| | | |||||
| * | Fix KafkaConsumer docstring for request_timeout_ms default (#1459) | Dana Powers | 2018-03-23 | 1 | -2/+2 |
| | | |||||
| * | Do not validate api_version against known versions (#1434) | Dana Powers | 2018-03-10 | 1 | -16/+1 |
| | | |||||
| * | Add BrokerConnection.connect_blocking() (#1411) | Dana Powers | 2018-03-09 | 1 | -5/+1 |
| | | |||||
| * | Check timeout type in KafkaClient constructor | Andre Araujo | 2018-02-21 | 1 | -0/+2 |
| | | | | | | | | | | | If a future was passed as the only positional parameter it would be assigned to the "timeout_ms" parameter erroneously. This mistake would not raise any exception but would lead to odd behaviour later, what could make it extremely difficult to troubleshoot. Adding a type check ensures that an exception is raise earlier to notify the user about the problem. | ||||
| * | Fix pending completion IndexError bug caused by multiple threads (#1372) | Dana Powers | 2018-02-08 | 1 | -2/+8 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 1 | -12/+12 |
| | | |||||
| * | Remove assertion with side effect (#1348) | Buğra Gedik | 2018-01-23 | 1 | -2/+2 |
| | | |||||
| * | 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 | ||||
| * | Improve KafkaConsumer cleanup (#1339) | Dana Powers | 2018-01-10 | 1 | -8/+17 |
| | | |||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -283/+182 |
| | | |||||
| * | use python standard max value (#1303) | lukeWx | 2017-12-07 | 1 | -1/+1 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |