diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 09:22:11 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-16 09:22:11 -0700 |
| commit | a7000baaedc4b2e3502e3d381687a6df9ba7c2d3 (patch) | |
| tree | 8d8b2c02b3c28bda437c6914f165b7782a54adeb /test | |
| parent | 7a350e5fcf33f49094c820ba88b9cee4aeae6e12 (diff) | |
| download | kafka-python-a7000baaedc4b2e3502e3d381687a6df9ba7c2d3.tar.gz | |
Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)
* Dont wait for group join to enable AutoCommitTask if broker version < 0.9
* For zookeeper offset storage, set a "coordinator" with least_loaded_node
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) |