summaryrefslogtreecommitdiff
path: root/test/test_coordinator.py
Commit message (Collapse)AuthorAgeFilesLines
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-34/+33
|
* KAFKA-3318: clean up consumer logging and error messagesDana Powers2016-04-051-3/+3
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-3/+2
|
* Test _maybe_auto_commit_offsets_sync when group_id is NoneDana Powers2016-04-031-19/+35
|
* Add test for unknown coordinator heartbeat taskDana Powers2016-03-121-2/+14
|
* Mock client.ready() call to test coordinator offset fetch requestDana Powers2016-02-191-0/+1
|
* break up some circular references and close client wake pipe on __del__aisch2016-02-161-1/+2
|
* Add RangePartitionAssignor (and use as default); add assignor testsrange_assignorDana Powers2016-02-161-7/+11
|
* Add mocking to test_coordinator::test_close to fix random test failure (via ↵Dana Powers2016-01-111-0/+1
| | | | travis logs)
* Add ConsumerCoordinator unit testsDana Powers2016-01-101-0/+568