delta/python-packages/kafka-python.git/kafka/coordinator, branch issue_619github.com: mumrah/kafka-python.git
Improve auto-commit task handling when group_id is None2016-04-03T16:29:36+00:00Dana Powersdana.powers@gmail.com2016-04-03T16:29:36+00:003d1c3521db701047215831d4f84a6c653f087250
Check for None returned from least_loaded_node when no brokers are available2016-03-14T06:49:55+00:00Dana Powersdana.powers@gmail.com2016-03-14T06:49:55+00:008303780259375374b6be6c4b1813d077f5a99d7a
Log successful heartbeat as INFO; improve heartbeat response logging2016-03-12T23:08:36+00:00Dana Powersdana.powers@gmail.com2016-03-12T00:47:46+00:0086d98c00fdda7f0d9f2cccb64e2128977bd5ee8d
HeartbeatTask should reschedule heartbeat on coordinator_unknown()2016-03-12T23:08:36+00:00Dana Powersdana.powers@gmail.com2016-03-12T00:41:42+00:000057e75ecfff12dcc16ec5b285c7288666798552
Mock client.ready() call to test coordinator offset fetch request2016-02-19T15:56:44+00:00Dana Powersdana.powers@gmail.com2016-02-19T06:56:05+00:0029e96f82ce0b028c21dc35fed2f4c26da4c8efef
Some attributes may not exist in __del__ if we failed assertions2016-02-19T05:53:11+00:00Dana Powersdana.powers@gmail.com2016-02-19T05:53:11+00:002dd216b5acafb89d177a79ec779374c5a6f94dcf
More friendly warning when offset fetch request returns unknown topic / partition2016-02-19T05:48:39+00:00Dana Powersdana.powers@gmail.com2016-02-19T05:48:39+00:0072fa7ef4fdb5be215aab7a075ad2257acbb059aa
Verify node ready before sending offset fetch request from coordinator2016-02-19T05:48:14+00:00Dana Powersdana.powers@gmail.com2016-02-19T05:48:14+00:006946aa29106eaea4db6dc0166909be590db9d276
break up some circular references and close client wake pipe on __del__2016-02-17T05:30:38+00:00aischme+bosch@aitmp.com2016-02-17T05:30:38+00:00d7522b0fb79bffbe10a2548658a48829dd1a5c33
Add RangePartitionAssignor (and use as default); add assignor tests2016-02-16T20:41:00+00:00Dana Powersdana.powers@gmail.com2016-02-16T20:35:28+00:00c8be93b44bb0939dd512a72be578d42a4d7426b7