diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-17 08:37:44 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-17 08:37:44 -0700 |
| commit | dd50847a9beaa9490ae35c7b1bc18d0780b92726 (patch) | |
| tree | 587db9e953a414ecc7d37c7bbe4660a32fafa9f1 /test | |
| parent | 31a29ecea000ad8e95b0ecb1b8e11f9600029135 (diff) | |
| download | kafka-python-dd50847a9beaa9490ae35c7b1bc18d0780b92726.tar.gz | |
KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)
Diffstat (limited to 'test')
| -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 |