diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_coordinator.py | 7 | ||||
| -rw-r--r-- | test/test_fetcher.py | 2 |
2 files changed, 4 insertions, 5 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 35598e8..4115c03 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -29,8 +29,7 @@ def client(conn): @pytest.fixture def coordinator(client): - return ConsumerCoordinator(client, SubscriptionState(), Metrics(), - 'consumer') + return ConsumerCoordinator(client, SubscriptionState(), Metrics()) def test_init(client, coordinator): @@ -42,7 +41,7 @@ def test_init(client, coordinator): @pytest.mark.parametrize("api_version", [(0, 8, 0), (0, 8, 1), (0, 8, 2), (0, 9)]) def test_autocommit_enable_api_version(client, api_version): coordinator = ConsumerCoordinator(client, SubscriptionState(), - Metrics(), 'consumer', + Metrics(), enable_auto_commit=True, group_id='foobar', api_version=api_version) @@ -362,7 +361,7 @@ def test_maybe_auto_commit_offsets_sync(mocker, api_version, group_id, enable, mock_exc = mocker.patch('kafka.coordinator.consumer.log.exception') client = KafkaClient(api_version=api_version) coordinator = ConsumerCoordinator(client, SubscriptionState(), - Metrics(), 'consumer', + Metrics(), api_version=api_version, enable_auto_commit=enable, group_id=group_id) diff --git a/test/test_fetcher.py b/test/test_fetcher.py index 1f1f7d3..6afd547 100644 --- a/test/test_fetcher.py +++ b/test/test_fetcher.py @@ -30,7 +30,7 @@ def fetcher(client, subscription_state): subscription_state.assign_from_subscribed(assignment) for tp in assignment: subscription_state.seek(tp, 0) - return Fetcher(client, subscription_state, Metrics(), 'test_fetcher') + return Fetcher(client, subscription_state, Metrics()) def test_init_fetches(fetcher, mocker): |