delta/python-packages/kafka-python.git/test/test_coordinator.py, branch 1.0.2 github.com: mumrah/kafka-python.git Add test for unknown coordinator heartbeat task 2016-03-12T23:08:36+00:00 Dana Powers dana.powers@gmail.com 2016-03-12T00:36:24+00:00 f58b7e9b2aaaa6891b6ad0331b6aa8cce55d97f4 






Mock client.ready() call to test coordinator offset fetch request
2016-02-19T15:56:44+00:00

Dana Powers
dana.powers@gmail.com

2016-02-19T06:56:05+00:00

29e96f82ce0b028c21dc35fed2f4c26da4c8efef












break up some circular references and close client wake pipe on __del__
2016-02-17T05:30:38+00:00

aisch
me+bosch@aitmp.com

2016-02-17T05:30:38+00:00

d7522b0fb79bffbe10a2548658a48829dd1a5c33












Add RangePartitionAssignor (and use as default); add assignor tests
2016-02-16T20:41:00+00:00

Dana Powers
dana.powers@gmail.com

2016-02-16T20:35:28+00:00

c8be93b44bb0939dd512a72be578d42a4d7426b7












Add mocking to test_coordinator::test_close to fix random test failure (via travis logs)
2016-01-12T00:09:04+00:00

Dana Powers
dana.powers@rd.io

2016-01-12T00:09:04+00:00

dcad3fea16028ae00f64baa981553b62666b15fb












Add ConsumerCoordinator unit tests
2016-01-10T19:10:23+00:00

Dana Powers
dana.powers@rd.io

2016-01-10T11:15:47+00:00

240f7029def4027bfccde7b8627c978ab1fdd5a6