diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 23:20:38 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-16 23:50:34 -0700 |
| commit | 277e4734757638678471b8682b52c9c5fe2839a4 (patch) | |
| tree | 177841b9805b282e67102fb89302672df307c20b /test/test_coordinator.py | |
| parent | 506d023978e7273bd323c0750e3f77af259d257b (diff) | |
| download | kafka-python-KAFKA-3117.tar.gz | |
KAFKA-3117: handle metadata updates during consumer rebalanceKAFKA-3117
Diffstat (limited to 'test/test_coordinator.py')
| -rw-r--r-- | test/test_coordinator.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 3435292..280fa70 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -85,7 +85,7 @@ def test_pattern_subscription(coordinator, api_version): coordinator.config['api_version'] = api_version coordinator._subscription.subscribe(pattern='foo') assert coordinator._subscription.subscription == set([]) - assert coordinator._subscription_metadata_changed() is False + assert coordinator._subscription_metadata_changed({}) is False assert coordinator._subscription.needs_partition_assignment is False cluster = coordinator._client.cluster |