summaryrefslogtreecommitdiff
path: root/test/test_client_async.py
Commit message (Collapse)AuthorAgeFilesLines
* Whitespace cleanup in test_client_asyncconnect_blockingDana Powers2018-03-091-0/+1
|
* Fixup client_async tests for connect_blockingDana Powers2018-03-091-3/+4
|
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-11/+0
|
* Drop unused sleep kwarg to poll (#1177)Dana Powers2017-08-151-17/+16
|
* Timeout idle connections via connections_max_idle_ms (#1068)Dana Powers2017-04-101-2/+36
|
* Avoid multiple connection attempts when refreshing metadata (#1067)Dana Powers2017-04-051-14/+25
|
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-2/+3
|
* Spelling and grammar changes (#923)melissacrawford3962017-01-111-1/+1
|
* Add metadata update to pattern subscribing (#915)Dmitry Lazurkin2016-12-271-2/+26
|
* Instrument metrics in BrokerConnectionDana Powers2016-08-041-0/+2
|
* Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-011-1/+1
|
* Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-161-2/+2
|
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-92/+48
|
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-201-2/+100
|
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-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 namesJames Brown2016-04-241-7/+7
| | | | Fixes #641
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-1/+14
|
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-2/+8
|
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵Dana Powers2016-04-081-10/+24
| | | | callback
* Split test_ready to test_is_readyDana Powers2016-04-081-34/+21
|
* Default sleep=True in client.pollDana Powers2016-04-081-4/+4
|
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-081-6/+5
|
* Consolidate conn fixture definitionsDana Powers2016-04-071-15/+0
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-4/+4
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
|
* Improve KafkaClient connect and ready handlingnode_not_readyDana Powers2016-04-041-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 Evens2016-03-301-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 Powers2016-01-231-4/+5
|
* Fix delayed_task timeout commit 45d26b6Dana Powers2016-01-101-3/+3
|
* Check delayed task timeout in client.poll()Dana Powers2016-01-101-2/+28
|
* Fill out more async client unit testsDana Powers2016-01-091-18/+165
|
* Use parameterized pytests in test_client_async; add pytest-mocker pluginDana Powers2016-01-031-70/+94
|
* Skeleton tests for async kafka clientDana Powers2016-01-011-0/+103
View Lorry Controller Status