diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-12 08:40:14 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-16 08:11:31 -0700 |
| commit | 7fc032ccd058eb16c77c2168ceea4052e2b3c264 (patch) | |
| tree | 8d8b2c02b3c28bda437c6914f165b7782a54adeb /test | |
| parent | 79989a12ca7e8c97e707d6fb0f6c78479da88ab3 (diff) | |
| download | kafka-python-zk_autocommit.tar.gz | |
For zookeeper offset storage, set a "coordinator" with least_loaded_nodezk_autocommit
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_coordinator.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 15b915d..735d278 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -425,8 +425,7 @@ def test_send_offset_commit_request_fail(patched_coord, offsets): ((0, 9), OffsetCommitRequest[2])]) def test_send_offset_commit_request_versions(patched_coord, offsets, api_version, req_type): - # assuming fixture sets coordinator=0, least_loaded_node=1 - expect_node = 0 if api_version >= (0, 8, 2) else 1 + expect_node = 0 patched_coord.config['api_version'] = api_version patched_coord._send_offset_commit_request(offsets) @@ -522,7 +521,7 @@ def test_send_offset_fetch_request_fail(patched_coord, partitions): def test_send_offset_fetch_request_versions(patched_coord, partitions, api_version, req_type): # assuming fixture sets coordinator=0, least_loaded_node=1 - expect_node = 0 if api_version >= (0, 8, 2) else 1 + expect_node = 0 patched_coord.config['api_version'] = api_version patched_coord._send_offset_fetch_request(partitions) |