From b6c6a27de83bd720aa866dc2332e21f2816ea972 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Thu, 23 May 2019 23:14:37 -0700 Subject: Remove string support in `api_version` A long time ago, `api_version` supported strings. That has been deprecated for years in favor of tuples. Time to remove support for the strings. --- test/test_producer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'test') diff --git a/test/test_producer.py b/test/test_producer.py index 60b19bf..b33b257 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -73,9 +73,9 @@ def test_end_to_end(kafka_broker, compression): def test_kafka_producer_gc_cleanup(): gc.collect() threads = threading.active_count() - producer = KafkaProducer(api_version='0.9') # set api_version explicitly to avoid auto-detection + producer = KafkaProducer(api_version=(0, 9)) # set api_version explicitly to avoid auto-detection assert threading.active_count() == threads + 1 - del(producer) + del producer gc.collect() assert threading.active_count() == threads -- cgit v1.2.1