delta/python-packages/kafka-python.git/kafka/coordinator, branch protocol_versions

Use version-indexed lists for request/response protocol structs

2016-04-06T05:54:28+00:00

Remove unused imports

2016-04-05T17:22:54+00:00

KAFKA-3318: clean up consumer logging and error messages

2016-04-05T17:22:54+00:00

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Merge pull request #589 from dpkp/node_not_ready

2016-04-04T23:09:10+00:00

Refactor NodeNotReadyError handling

Improve Coordinator Error handling

2016-04-04T21:42:50+00:00

 - coordinator_unknown() should not check ready(node_id)
 - dont mark coordinator dead on not-ready or inflight-requests errors
 - improve coordinator and heartbeat logging
 - dont gate group metadata requests on ready() check [conn handles now]

Improve auto-commit task handling when group_id is None

2016-04-03T16:29:36+00:00

Check for None returned from least_loaded_node when no brokers are available

2016-03-14T06:49:55+00:00

Log successful heartbeat as INFO; improve heartbeat response logging

2016-03-12T23:08:36+00:00

HeartbeatTask should reschedule heartbeat on coordinator_unknown()

2016-03-12T23:08:36+00:00