diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
index 6bd66ef13..1c7c5fa13 100644
--- a/faust/transport/drivers/aiokafka.py
+++ b/faust/transport/drivers/aiokafka.py
@@ -1563,9 +1563,9 @@ async def _really_create_topic(
             return
         response = wait_result.result
 
-        assert len(response.topic_error_codes), "single topic"
+        assert len(response.topic_errors), "single topic"
 
-        _, code, reason = response.topic_error_codes[0]
+        _, code, reason = response.topic_errors[0]
 
         if code != 0:
             if not ensure_created and code == TopicExistsError.errno:
diff --git a/requirements/requirements.txt b/requirements/requirements.txt
index 5b7f71c9b..f1f2e6d53 100644
--- a/requirements/requirements.txt
+++ b/requirements/requirements.txt
@@ -1,6 +1,6 @@
 aiohttp>=3.8.0,<4.0
 aiohttp_cors>=0.7,<2.0
-aiokafka>=0.9.0
+aiokafka>=0.10.0
 click>=6.7,<8.2
 mode-streaming>=0.4.0
 opentracing>=1.3.0,<=2.4.0