| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Send socket data via non-blocking IO with send buffer (#1912) | Dana Powers | 2019-09-29 | 1 | -1/+3 |
| | | |||||
| * | Rely on socket selector to detect completed connection attempts (#1909) | Dana Powers | 2019-09-28 | 1 | -1/+1 |
| | | |||||
| * | Reduce client poll timeout when no ifrs | Dana Powers | 2019-05-29 | 1 | -0/+12 |
| | | |||||
| * | Remove unused imports (#1808) | Jeff Widman | 2019-05-22 | 1 | -5/+1 |
| | | |||||
| * | Do not call state_change_callback with lock (#1775) | Dana Powers | 2019-04-02 | 1 | -10/+11 |
| | | |||||
| * | Dont treat popped conn.close() as failure in state change callback (#1773) | Dana Powers | 2019-04-01 | 1 | -2/+3 |
| | | |||||
| * | Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769) | Dana Powers | 2019-03-30 | 1 | -2/+2 |
| | | |||||
| * | Retry bootstrapping after backoff when necessary (#1736) | Dana Powers | 2019-03-14 | 1 | -45/+23 |
| | | | | | | | | 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 | ||||
| * | Recheck connecting nodes sooner when refreshing metadata (#1737) | Dana Powers | 2019-03-13 | 1 | -1/+1 |
| | | |||||
| * | Do network connections and writes in KafkaClient.poll() (#1729) | Dana Powers | 2019-03-08 | 1 | -5/+4 |
| | | | | | | | * 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() | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 1 | -2/+1 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Add BrokerConnection.connect_blocking() (#1411) | Dana Powers | 2018-03-09 | 1 | -3/+5 |
| | | |||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -11/+0 |
| | | |||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 1 | -17/+16 |
| | | |||||
| * | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 1 | -2/+36 |
| | | |||||
| * | Avoid multiple connection attempts when refreshing metadata (#1067) | Dana Powers | 2017-04-05 | 1 | -14/+25 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 1 | -2/+3 |
| | | |||||
| * | Spelling and grammar changes (#923) | melissacrawford396 | 2017-01-11 | 1 | -1/+1 |
| | | |||||
| * | Add metadata update to pattern subscribing (#915) | Dmitry Lazurkin | 2016-12-27 | 1 | -2/+26 |
| | | |||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -0/+2 |
| | | |||||
| * | Move kafka.selectors34 to kafka.vendor.selectors34 | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Add rack to BrokerMetadata - it is always None when using MetadataRequest v0 | Dana Powers | 2016-07-16 | 1 | -2/+2 |
| | | |||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 1 | -92/+48 |
| | | |||||
| * | Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) | Dana Powers | 2016-06-20 | 1 | -2/+100 |
| | | |||||
| * | Fix socket leaks in KafkaClient (#696) | Dana Powers | 2016-05-22 | 1 | -3/+6 |
| | | | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close() | ||||
| * | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 1 | -7/+7 |
| | | | | | Fixes #641 | ||||
| * | Use selectors module in KafkaClientselectors | Dana Powers | 2016-04-09 | 1 | -1/+14 |
| | | |||||
| * | Add state_change_callback to bootstrap connectionconn_state_callback | Dana Powers | 2016-04-08 | 1 | -2/+8 |
| | | |||||
| * | Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵ | Dana Powers | 2016-04-08 | 1 | -10/+24 |
| | | | | | callback | ||||
| * | Split test_ready to test_is_ready | Dana Powers | 2016-04-08 | 1 | -34/+21 |
| | | |||||
| * | Default sleep=True in client.poll | Dana Powers | 2016-04-08 | 1 | -4/+4 |
| | | |||||
| * | Add BrokerConnection.disconnected() method; update tests | Dana Powers | 2016-04-08 | 1 | -6/+5 |
| | | |||||
| * | Consolidate conn fixture definitions | Dana Powers | 2016-04-07 | 1 | -15/+0 |
| | | |||||
| * | Use version-indexed lists for request/response protocol structsprotocol_versions | Dana Powers | 2016-04-05 | 1 | -4/+4 |
| | | |||||
| * | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -2/+2 |
| | | |||||
| * | Improve KafkaClient connect and ready handlingnode_not_ready | Dana Powers | 2016-04-04 | 1 | -44/+40 |
| | | | | | | | - merge _initiate and _finish into _maybe_connect - add connected(node_id) method - only short-circuit send() when not connected | ||||
| * | Kafka IPv6 Support. | Tim Evens | 2016-03-30 | 1 | -7/+8 |
| | | | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234). | ||||
| * | Fix client poll tests (called with sleep=False) | Dana Powers | 2016-01-23 | 1 | -4/+5 |
| | | |||||
| * | Fix delayed_task timeout commit 45d26b6 | Dana Powers | 2016-01-10 | 1 | -3/+3 |
| | | |||||
| * | Check delayed task timeout in client.poll() | Dana Powers | 2016-01-10 | 1 | -2/+28 |
| | | |||||
| * | Fill out more async client unit tests | Dana Powers | 2016-01-09 | 1 | -18/+165 |
| | | |||||
| * | Use parameterized pytests in test_client_async; add pytest-mocker plugin | Dana Powers | 2016-01-03 | 1 | -70/+94 |
| | | |||||
| * | Skeleton tests for async kafka client | Dana Powers | 2016-01-01 | 1 | -0/+103 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |