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

Fix coordinator join_future race condition (#1338)

2018-01-11T22:48:38+00:00

* Fix race condition in coordinator join_future handling

Improve KafkaConsumer cleanup (#1339)

2018-01-10T23:56:47+00:00

KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

2017-12-21T22:46:10+00:00

Replace periods (java) with underscores (python)

2017-11-07T23:16:06+00:00

Handle lookup_coordinator send failures (#1279)

2017-10-24T23:05:50+00:00

KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)

2017-10-12T00:11:31+00:00

Explicitly check for `None` rather than False

2017-10-06T21:44:04+00:00

If the group leader somehow gets in a state that it has an empty partition assignment, then `self._assignment_snapshot` will be `{}` which evaluates to `False`. So `self._subscription.mark_for_reassignment()` will never be triggered, even if `self._assignment_snapshot != self._metadata_snapshot`. 

Fixes the symptoms of https://github.com/dpkp/kafka-python/issues/1237 although I suspect there's an additional bug in that case that triggers the condition of the the group leader getting an empty partition assignment.

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.