summaryrefslogtreecommitdiff
path: root/test/test_fetcher.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-07-16 10:29:37 -0700
committerDana Powers <dana.powers@gmail.com>2016-07-16 12:07:26 -0700
commit2c4b9cdf2cc18ccd40d2489e74766c6b702c2725 (patch)
tree72be396969e5f04509787f496219c0c8b298336b /test/test_fetcher.py
parent061cb4e83469166873912fca2aac62ca8376377f (diff)
downloadkafka-python-client_api_version.tar.gz
Add api_version config to KafkaClient, deprecate str in favor of tuplesclient_api_version
Diffstat (limited to 'test/test_fetcher.py')
-rw-r--r--test/test_fetcher.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_fetcher.py b/test/test_fetcher.py
index 7e529bc..1f1f7d3 100644
--- a/test/test_fetcher.py
+++ b/test/test_fetcher.py
@@ -15,7 +15,7 @@ from kafka.structs import TopicPartition, OffsetAndMetadata
@pytest.fixture
def client(mocker):
- return mocker.Mock(spec=KafkaClient(bootstrap_servers=[]))
+ return mocker.Mock(spec=KafkaClient(bootstrap_servers=[], api_version=(0, 9)))
@pytest.fixture