summaryrefslogtreecommitdiff
path: root/test/test_coordinator.py
Commit message (Expand)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 t...Dana Powers2016-01-111-0/+1
* Add ConsumerCoordinator unit testsDana Powers2016-01-101-0/+568