fix tests

Author: rohitsanj

requirements/requirements-tests.txt

@@ -9,3 +9,4 @@ requests-mock
 respx
 pytest_cov
 pytest-asyncio
+async-timeout

tests/common/_async/__init__.py

@@ -15,8 +15,12 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-
+import sys
 import asyncio
+if sys.version_info >= (3, 11):
+    from asyncio import timeout
+else:
+    from async_timeout import timeout
 
 from confluent_kafka.cimpl import Consumer
 from confluent_kafka.error import ConsumeError, KeyDeserializationError, ValueDeserializationError

tests/common/_async/consumer.py

@@ -28,6 +28,7 @@
 import gc
 import struct
 import re
+import pytest
 
 import confluent_kafka
 
@@ -212,7 +213,7 @@ def verify_producer():
 # Global variable to track garbage collection of suppressed on_delivery callbacks
 DrOnlyTestSuccess_gced = 0
 
-
+@pytest.mark.skip(reason="This module must be run as a script")
 def test_producer_dr_only_error():
     """
     The C delivery.report.only.error configuration property