fix(aiokafka): use AsyncMock to fix unawaited coroutine warning

Author: dorlib

instrumentation/opentelemetry-instrumentation-aiokafka/tests/test_utils.py

@@ -256,7 +256,7 @@ async def test_wrap_getmany(
         extract_bootstrap_servers: mock.MagicMock,
         _enrich_getmany_poll_span: mock.MagicMock,
         _enrich_getmany_topic_span: mock.MagicMock,
-        _create_consumer_span: mock.MagicMock,
+        _create_consumer_span: mock.AsyncMock,
         extract: mock.MagicMock,
     ) -> None:
         tracer = mock.MagicMock()
@@ -270,6 +270,7 @@ async def test_wrap_getmany(
             }
         )
         kafka_consumer = mock.MagicMock()
+        _create_consumer_span.return_value = mock.MagicMock()
 
         wrapped_getmany = _wrap_getmany(tracer, consume_hook)
         records = await wrapped_getmany(