diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 10:31:01 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-16 10:31:01 -0700 |
| commit | 061cb4e83469166873912fca2aac62ca8376377f (patch) | |
| tree | bd8cd0fed9910bd89c42d908545bca61181df48c | |
| parent | a7000baaedc4b2e3502e3d381687a6df9ba7c2d3 (diff) | |
| download | kafka-python-061cb4e83469166873912fca2aac62ca8376377f.tar.gz | |
Include zk-offset configuration in coordinator unit tests
| -rw-r--r-- | test/test_coordinator.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 735d278..bb62b7b 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -344,7 +344,9 @@ def test_commit_offsets_sync(mocker, coordinator, offsets): @pytest.mark.parametrize( 'api_version,group_id,enable,error,has_auto_commit,commit_offsets,warn,exc', [ - ((0, 8), 'foobar', True, None, False, False, True, False), + ((0, 8, 0), 'foobar', True, None, False, False, True, False), + ((0, 8, 1), 'foobar', True, None, True, True, False, False), + ((0, 8, 2), 'foobar', True, None, True, True, False, False), ((0, 9), 'foobar', False, None, False, False, False, False), ((0, 9), 'foobar', True, Errors.UnknownMemberIdError(), True, True, True, False), ((0, 9), 'foobar', True, Errors.IllegalGenerationError(), True, True, True, False), @@ -367,7 +369,9 @@ def test_maybe_auto_commit_offsets_sync(mocker, api_version, group_id, enable, side_effect=error) if has_auto_commit: assert coordinator._auto_commit_task is not None - coordinator._auto_commit_task.enable() + # auto-commit enable is defered until after group join in 0.9+ + if api_version >= (0, 9): + coordinator._auto_commit_task.enable() assert coordinator._auto_commit_task._enabled is True else: assert coordinator._auto_commit_task is None |