diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2019-05-23 23:14:37 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-05-24 00:17:39 -0700 |
| commit | b6c6a27de83bd720aa866dc2332e21f2816ea972 (patch) | |
| tree | 80430f69fbf95ffc15cd23904ea0f1556a4fda39 /test | |
| parent | cee4d17df7858439e0dbdf3914ca0107e080af7d (diff) | |
| download | kafka-python-Remove-support-for-api_version-strings.tar.gz | |
Remove string support in `api_version`Remove-support-for-api_version-strings
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.
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_producer.py | 4 |
1 files changed, 2 insertions, 2 deletions
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 |