Narrow down the cause of test timeout in test/test_producer.py

test/test_producer.py

@@ -12,7 +12,7 @@
 
 
 @pytest.mark.skipif(env_kafka_version() <= (0, 8, 2) and sys.version_info > (3, 11), reason="Kafka 0.8.2 and earlier not supported by 3.12")
-def test_buffer_pool():
+def xtest_buffer_pool():
     pool = SimpleBufferPool(1000, 1000)
 
     buf1 = pool.allocate(1000, 1000)
@@ -26,7 +26,7 @@ def test_buffer_pool():
 @pytest.mark.skipif(not env_kafka_version(), reason="No KAFKA_VERSION set")
 @pytest.mark.skipif(env_kafka_version() <= (0, 8, 2) and sys.version_info > (3, 11), reason="Kafka 0.8.2 and earlier not supported by 3.12")
 @pytest.mark.parametrize("compression", [None, 'gzip', 'snappy', 'lz4', 'zstd'])
-def test_end_to_end(kafka_broker, compression):
+def xtest_end_to_end(kafka_broker, compression):
     if compression == 'lz4':
         if env_kafka_version() < (0, 8, 2):
             pytest.skip('LZ4 requires 0.8.2')
@@ -73,7 +73,7 @@ def test_end_to_end(kafka_broker, compression):
 @pytest.mark.skipif(platform.python_implementation() != 'CPython',
                     reason='Test relies on CPython-specific gc policies')
 @pytest.mark.skipif(env_kafka_version() <= (0, 8, 2) and sys.version_info > (3, 11), reason="Kafka 0.8.2 and earlier not supported by 3.12")
-def test_kafka_producer_gc_cleanup():
+def xtest_kafka_producer_gc_cleanup():
     gc.collect()
     threads = threading.active_count()
     producer = KafkaProducer(api_version='0.9') # set api_version explicitly to avoid auto-detection
@@ -85,7 +85,7 @@ def test_kafka_producer_gc_cleanup():
 
 @pytest.mark.skipif(not env_kafka_version(), reason="No KAFKA_VERSION set")
 @pytest.mark.skipif(env_kafka_version() <= (0, 8, 2) and sys.version_info > (3, 11), reason="Kafka 0.8.2 and earlier not supported by 3.12")
-@pytest.mark.parametrize("compression", [None, 'gzip', 'snappy', 'lz4', 'zstd'])
+@pytest.mark.parametrize("compression", ['gzip', 'snappy', 'lz4', 'zstd'])
 def test_kafka_producer_proper_record_metadata(kafka_broker, compression):
     if compression == 'zstd' and env_kafka_version() < (2, 1, 0):
         pytest.skip('zstd requires 2.1.0 or more')