summaryrefslogtreecommitdiff
path: root/test/test_client_async.py
Commit message (Collapse)AuthorAgeFilesLines
* 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