From 232c4cf23d71e9e06a3695a38bd7a7735ad14860 Mon Sep 17 00:00:00 2001 From: William Barnhart Date: Wed, 7 Aug 2024 19:16:44 -0400 Subject: [PATCH] rename to topic_errors for newer versions of aiokafka and bump minimum version to v0.10.0 (#639) --- faust/transport/drivers/aiokafka.py | 4 ++-- requirements/requirements.txt | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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