tests: increase confluent tests timeouts

docs/docs_src/getting_started/subscription/confluent/real_testing.py

@@ -10,7 +10,7 @@
 async def test_handle():
     async with TestKafkaBroker(broker, with_real=True) as br:
         await br.publish({"name": "John", "user_id": 1}, topic="test-topic-confluent")
-        await handle.wait_call(timeout=10)
+        await handle.wait_call(timeout=20)
         handle.mock.assert_called_once_with({"name": "John", "user_id": 1})
 
     assert handle.mock is None
@@ -20,6 +20,6 @@ async def test_validation_error():
     async with TestKafkaBroker(broker, with_real=True) as br:
         with pytest.raises(ValidationError):
             await br.publish("wrong message", topic="test-confluent-wrong-fields")
-            await wrong_handle.wait_call(timeout=10)
+            await wrong_handle.wait_call(timeout=20)
 
         wrong_handle.mock.assert_called_once_with("wrong message")

tests/docs/confluent/ack/test_errors.py

@@ -17,6 +17,6 @@ async def test_ack_exc():
         AsyncConfluentConsumer, "commit", spy_decorator(AsyncConfluentConsumer.commit)
     ) as m:
         async with TestKafkaBroker(broker, with_real=True), TestApp(app):
-            await handle.wait_call(10)
+            await handle.wait_call(20)
 
             assert m.mock.call_count

tests/docs/getting_started/publishing/test_broker_context.py

@@ -38,7 +38,7 @@ async def test_broker_context_confluent():
     from faststream.confluent import TestKafkaBroker as TestConfluentKafkaBroker
 
     async with TestConfluentKafkaBroker(broker, with_real=True), TestApp(app):
-        await handle.wait_call(10)
+        await handle.wait_call(20)
         handle.mock.assert_called_once_with("Hi!")