diff --git a/tests/pykafka/test_producer.py b/tests/pykafka/test_producer.py index 7c6fe913b..b2d647c3c 100644 --- a/tests/pykafka/test_producer.py +++ b/tests/pykafka/test_producer.py @@ -388,6 +388,9 @@ def ensure_all_messages_consumed(): [CompressionType.LZ4], ]) def test_sync_produce_compression_large_message(self, compression_type): + if platform.python_implementation() == 'PyPy' and compression_type == CompressionType.LZ4: + pytest.skip("PyPy doesn't work well with LZ4") + consumer = self._get_consumer() prod = self._get_producer(sync=True, min_queued_messages=1, compression=compression_type)