diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-01-26 20:35:22 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-01-26 21:51:29 -0800 |
| commit | f08ec792ee93fd059e81ee1e30f5651c15f69e85 (patch) | |
| tree | 6698c6b28681d35edbfe5ca9ff385c8664f33ee1 /test/test_producer.py | |
| parent | 66284e57accec5977d606fc91a0b28177b352eb4 (diff) | |
| download | kafka-python-f08ec792ee93fd059e81ee1e30f5651c15f69e85.tar.gz | |
Handle broken LZ4 framing; switch to lz4tools + xxhashlz4_fixup
Diffstat (limited to 'test/test_producer.py')
| -rw-r--r-- | test/test_producer.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index 7a2db68..36da68d 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -1,3 +1,5 @@ +import sys + import pytest from kafka import KafkaConsumer, KafkaProducer @@ -9,9 +11,13 @@ from test.testutil import random_string @pytest.mark.parametrize("compression", [None, 'gzip', 'snappy', 'lz4']) def test_end_to_end(kafka_broker, compression): - # LZ4 requires 0.8.2 - if compression == 'lz4' and version() < (0, 8, 2): - return + if compression == 'lz4': + # LZ4 requires 0.8.2 + if version() < (0, 8, 2): + return + # LZ4 python libs dont work on python2.6 + elif sys.version_info < (2, 7): + return connect_str = 'localhost:' + str(kafka_broker.port) producer = KafkaProducer(bootstrap_servers=connect_str, |