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

Initialize metadata_snapshot in group coordinator (#1174)

2017-08-13T18:47:33+00:00

Use for join-time-max and sync-time-max metrics Max() measure function (#1146)

2017-07-21T05:07:50+00:00

change_subscription called only when necessary (#1132)

2017-07-07T19:29:40+00:00

When we are using subscription by pattern change subscription is
called every metadata update even when nothing changes. This PR
ensures that change subscription is called only when set of topics
changes.

Backoff on unavailable group coordinator retry (#1125)

2017-06-19T16:18:56+00:00

Additional docstrings for autocommit close option

2017-03-13T23:39:53+00:00

Optionally skip auto-commit during consumer.close (#1031)

2017-03-13T23:39:23+00:00

Short-circuit group coordinator requests when NodeNotReady (#995)

2017-03-09T22:26:09+00:00

Avoid unknown coordinator after client poll (#1023)

2017-03-09T20:49:05+00:00

For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds

2017-03-07T19:32:36+00:00

Minor additional logging for consumer coordinator

2017-03-06T19:03:17+00:00